Prefect Collection to run Airbyte data replication sync jobs in your flows: prefect-airbyte

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()
2 Likes