Pranit
09/01/2022, 2:09 PMJeff Hale
09/01/2022, 2:15 PMPranit
09/01/2022, 2:16 PMFile "<frozen importlib._bootstrap_external>", line 848, in exec_module
File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
File "/home/pranitsherkar/prefect/talend_fact_shopify_dailysales_productperformance.py", line 8, in <module>
talend_fact_shopify_dailysales_productperformance()
File "/home/pranitsherkar/.local/lib/python3.8/site-packages/prefect/flows.py", line 384, in __call__
return enter_flow_run_engine_from_flow_call(
File "/home/pranitsherkar/.local/lib/python3.8/site-packages/prefect/engine.py", line 156, in enter_flow_run_engine_from_flow_call
return anyio.run(begin_run)
File "/home/pranitsherkar/.local/lib/python3.8/site-packages/anyio/_core/_eventloop.py", line 70, in run
return asynclib.run(func, *args, **backend_options)
File "/home/pranitsherkar/.local/lib/python3.8/site-packages/anyio/_backends/_asyncio.py", line 292, in run
return native_run(wrapper(), debug=debug)
File "/usr/lib/python3.8/asyncio/runners.py", line 44, in run
return loop.run_until_complete(main)
File "/usr/lib/python3.8/asyncio/base_events.py", line 616, in run_until_complete
return future.result()
File "/home/pranitsherkar/.local/lib/python3.8/site-packages/anyio/_backends/_asyncio.py", line 287, in wrapper
return await func(*args)
File "/home/pranitsherkar/.local/lib/python3.8/site-packages/prefect/client.py", line 104, in with_injected_client
return await fn(*args, **kwargs)
File "/home/pranitsherkar/.local/lib/python3.8/site-packages/prefect/engine.py", line 229, in create_then_begin_flow_run
state = await begin_flow_run(
File "/home/pranitsherkar/.local/lib/python3.8/site-packages/prefect/engine.py", line 357, in begin_flow_run
await result_filesystem._save(is_anonymous=True)
File "/home/pranitsherkar/.local/lib/python3.8/site-packages/prefect/blocks/core.py", line 688, in _save
await self.register_type_and_schema(client=client)
TypeError: object NoneType can't be used in 'await' expression
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "/home/pranitsherkar/.local/lib/python3.8/site-packages/prefect/engine.py", line 254, in retrieve_flow_then_begin_flow_run
flow = await load_flow_from_flow_run(flow_run, client=client)
File "/home/pranitsherkar/.local/lib/python3.8/site-packages/prefect/client.py", line 104, in with_injected_client
return await fn(*args, **kwargs)
File "/home/pranitsherkar/.local/lib/python3.8/site-packages/prefect/deployments.py", line 73, in load_flow_from_flow_run
flow = await run_sync_in_worker_thread(import_object, str(import_path))
File "/home/pranitsherkar/.local/lib/python3.8/site-packages/prefect/utilities/asyncutils.py", line 56, in run_sync_in_worker_thread
return await anyio.to_thread.run_sync(call, cancellable=True)
File "/home/pranitsherkar/.local/lib/python3.8/site-packages/anyio/to_thread.py", line 31, in run_sync
return await get_asynclib().run_sync_in_worker_thread(
File "/home/pranitsherkar/.local/lib/python3.8/site-packages/anyio/_backends/_asyncio.py", line 937, in run_sync_in_worker_thread
return await future
File "/home/pranitsherkar/.local/lib/python3.8/site-packages/anyio/_backends/_asyncio.py", line 867, in run
result = context.run(func, *args)
File "/home/pranitsherkar/.local/lib/python3.8/site-packages/prefect/utilities/importtools.py", line 193, in import_object
module = load_script_as_module(script_path)
File "/home/pranitsherkar/.local/lib/python3.8/site-packages/prefect/utilities/importtools.py", line 156, in load_script_as_module
raise ScriptError(user_exc=exc, path=path) from exc
prefect.exceptions.ScriptError: Script at '/home/pranitsherkar/prefect/talend_fact_shopify_dailysales_productperformance.py' encountered an exception
Jeff Hale
09/01/2022, 2:20 PMPranit
09/01/2022, 2:21 PMJeff Hale
09/01/2022, 2:25 PMPranit
09/01/2022, 2:26 PMJeff Hale
09/01/2022, 2:26 PMPranit
09/01/2022, 2:30 PMpython /home/pranitsherkar/prefect/talend_fact_shopify_dailysales_productperformance.py
2. When I am starting an agent and executing the deployment through cloud
TypeError: object NoneType can't be used in 'await' expression
prefect.exceptions.ScriptError: Script at '/home/pranitsherkar/prefect/talend_fact_shopify_dailysales_productperformance.py' encountered an exception
from prefect import flow
from prefect_airbyte.connections import trigger_sync
@flow
def airbyte_shopify_drinkdrummerboy():
# Run other tasks and subflows here
trigger_sync(
connection_id="",
poll_interval_s=3,
status_updates=True
)
airbyte_shopify_drinkdrummerboy()
Jeff Hale
09/01/2022, 4:50 PM