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'
06
3927 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'")