Madison Schott
11/15/2022, 5:55 PMfrom prefect_fivetran.connectors import fivetran_sync_flow
ImportError: cannot import name 'fivetran_sync_flow' from 'prefect_fivetran.connectors' (/usr/local/lib/python3.9/site-packages/prefect_fivetran/connectors.py)
Nate
11/15/2022, 6:03 PMfivetran_sync_flow
defined in that collection, I think you want this oneMadison Schott
11/15/2022, 6:03 PMNate
11/15/2022, 6:04 PMMadison Schott
11/15/2022, 7:24 PMfrom prefect_fivetran.connectors import fivetran_sync_flow
Nate
11/15/2022, 7:27 PMfivetran_sync_flow
in:
• the first readme / PyPI example
• here in connectors.pyMadison Schott
11/15/2022, 7:34 PMRuntimeError: A 'sync_compatible' method was called from a context that was previously async but is now sync. The sync call must be changed to run in a worker thread to support sending the coroutine for 'load' to the main thread.
@task
def webevent_sync(fivetran_credentials):
webevents_secret = Secret.load("webevents-connector_id")
webevents_sync = trigger_fivetran_connector_sync_and_wait_for_completion(
fivetran_credentials=fivetran_credentials,
connector_id=webevents_secret.get(),
schedule_type="manual",
poll_status_every_n_seconds=30,
)
Nate
11/15/2022, 9:36 PMprefect version
show?Madison Schott
11/15/2022, 9:37 PMVersion: 2.3.2
API version: 0.8.0
Python version: 3.9.13
Git commit: 6e931ee9
Built: Tue, Sep 6, 2022 12:36 PM
OS/Arch: darwin/x86_64
Profile: madisonschott
Server type: cloud
Nate
11/15/2022, 9:37 PMpip install -U prefect
? This issue should be handled in recent versionsMadison Schott
11/15/2022, 9:43 PMprefect.exceptions.ScriptError: Script at 'data_pipeline_2.0_prod.py' encountered an exception
An exception occurred.
sys:1: RuntimeWarning: coroutine 'Block.load' was never awaited
RuntimeWarning: Enable tracemalloc to get the object allocation traceback