Pranit
08/26/2022, 11:26 AMModuleNotFoundError: 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 pagespip install prefect-airbyte
Anna Geller
08/26/2022, 11:28 AMJeff Hale
08/26/2022, 11:28 AMPranit
08/26/2022, 11:29 AMJeff Hale
08/26/2022, 11:29 AMAnna Geller
08/26/2022, 11:29 AMPranit
08/26/2022, 11:32 AMAnna Geller
08/26/2022, 11:33 AMPranit
08/26/2022, 11:34 AMAnna Geller
08/26/2022, 11:34 AMPranit
08/26/2022, 11:34 AMAnna Geller
08/26/2022, 11:35 AMfrom 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()
Pranit
08/26/2022, 11:39 AMAnna Geller
08/26/2022, 11:44 AMPranit
08/26/2022, 11:45 AMfrom 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()