This the error i am getting: Downloading flow cod...
# prefect-getting-started
m
This the error i am getting: Downloading flow code from storage at '/root/Dry_run/DS_GCS/GCP_Source_GCS/Source_Connectors/adls-cloud-func' 063927 PM prefect.flow_runs ERROR Flow could not be retrieved from deployment. Traceback (most recent call last): File "<frozen importlib._bootstrap_external>", line 790, in exec_module File "<frozen importlib._bootstrap>", line 228, in _call_with_frames_removed File "main_connector.py", line 4, in <module> import const File "/tmp/tmpuiitur6_prefect/const.py", line 4, in <module> from adl_to_postgres.app_dashboard import app_main File "/tmp/tmpuiitur6_prefect/adl_to_postgres/app_dashboard/app_main.py", line 4, in <module> from trino.exceptions import TrinoQueryError, TrinoExternalError, OperationalError ModuleNotFoundError: No module named 'trino' The above exception was the direct cause of the following exception: Traceback (most recent call last): File "/usr/local/lib/python3.9/dist-packages/prefect/engine.py", line 394, in retrieve_flow_then_begin_flow_run flow = await load_flow_from_flow_run(flow_run, client=client) File "/usr/local/lib/python3.9/dist-packages/prefect/client/utilities.py", line 51, in with_injected_client return await fn(*args, **kwargs) File "/usr/local/lib/python3.9/dist-packages/prefect/deployments/deployments.py", line 232, in load_flow_from_flow_run flow = await run_sync_in_worker_thread(load_flow_from_entrypoint, str(import_path)) File "/usr/local/lib/python3.9/dist-packages/prefect/utilities/asyncutils.py", line 91, in run_sync_in_worker_thread return await anyio.to_thread.run_sync( File "/usr/local/lib/python3.9/dist-packages/anyio/to_thread.py", line 33, in run_sync return await get_asynclib().run_sync_in_worker_thread( File "/usr/local/lib/python3.9/dist-packages/anyio/_backends/_asyncio.py", line 877, in run_sync_in_worker_thread return await future File "/usr/local/lib/python3.9/dist-packages/anyio/_backends/_asyncio.py", line 807, in run result = context.run(func, *args) File "/usr/local/lib/python3.9/dist-packages/prefect/flows.py", line 1172, in load_flow_from_entrypoint flow = import_object(entrypoint) File "/usr/local/lib/python3.9/dist-packages/prefect/utilities/importtools.py", line 201, in import_object module = load_script_as_module(script_path) File "/usr/local/lib/python3.9/dist-packages/prefect/utilities/importtools.py", line 164, in load_script_as_module raise ScriptError(user_exc=exc, path=path) from exc prefect.exceptions.ScriptError: Script at 'main_connector.py' encountered an exception: ModuleNotFoundError("No module named 'trino'")
plus1 1
m
Same issue here. Did you find any resolution @Mathuraju Sivasankar ?
Are you also using Google Cloud Run?