Docs
https://prefecthq.github.io/prefect-airbyte/
Code
Examples
from prefect import flow
from prefect_airbyte.connections import trigger_sync
@flow
def example_trigger_sync_flow():
# Run other tasks and subflows here
trigger_sync(
connection_id="your-connection-id-to-sync",
poll_interval_s=3,
status_updates=True
)
example_trigger_sync_flow()