Hello I am trying to integrate prefect cloud with Airbyte. But I am facing below error

ModuleNotFoundError: No module named 'prefect.tasks.airbyte'; 'prefect.tasks' is not a package

Have I missed to install any dependency ? I didnt see anything on airbyte/prefect pages

this may help https://medium.com/the-prefect-blog/orchestrating-airbyte-with-prefect-2-0-35501997a974

Are you using Prefect 1 or 2?

2

Ah yes. The import you are using is for Prefect 1. Here are the docs for 2: https://prefecthq.github.io/prefect-airbyte/

there is indeed no module tasks here https://github.com/PrefectHQ/prefect-airbyte/tree/main/prefect_airbyte

@Anna Geller I am already following same page

there are no tasks

can you check examples from those docs? you may be using some outdated examples

Used the same example given on your page

try this:

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

tried, doent work

perhaps you can try in a new environment? otherwise, it might be worth opening an issue in the collection repo, providing MRE and explaining what doesn't work as expected

I executed this basic dag , which is working

from prefect import flow, get_run_logger

@flow(name="Testing")
def basic_flow():
    logger = get_run_logger()
    logger.warning("The fun is about to begin")

if __name__ == "__main__":
    basic_flow()