Darin Douglass
06/09/2022, 8:30 PMcreate_flow_run
that will cause two flows to spawn from the one call?Mike Larsson
06/09/2022, 8:39 PMJessica Smith
06/09/2022, 9:10 PMSlackbot
06/10/2022, 8:26 AMSlackbot
06/10/2022, 8:44 AMUsman Abdulkareem Adedayo
06/10/2022, 8:46 AMDavid Maier
06/10/2022, 8:58 AMSlackbot
06/10/2022, 9:00 AMAndreas Nigg
06/10/2022, 9:06 AMFlorian Guily
06/10/2022, 10:18 AMHemabh Kamboj
06/10/2022, 11:24 AMFailed to load and execute flow run: FlowStorageError('An error occurred while unpickling the flow:\n ModuleNotFoundError("No module named \'google.api\'")\nThis may be due to a missing Python module in your current environment. Please ensure you have all required flow dependencies installed.')
I tried running the flow by putting the flow.run
instead of flow.register
and then ran the flow using python3 workflow.py
. And its running fine. The agent is installed on the same machine from where I ran the flow manually. So registering and running are done from the same machine.
So I cannot understand why such error is thrown.
Can anybody help?Danilo Drobac
06/10/2022, 11:39 AMprefect cloud login --key {key} --workspace {workspace}
related to timeouts?
I'm trying to run the command in a CI/CD pipeline through Google Cloud Build but it fails due to a timeout and I have very little information in the error.Martin T
06/10/2022, 12:00 PMRajvir Jhawar
06/10/2022, 12:37 PMJessica Smith
06/10/2022, 12:52 PMRamzi A
06/10/2022, 2:06 PMSushma Adari
06/10/2022, 2:36 PMIlya Sapunov
06/10/2022, 3:31 PMZhibin Dai
06/10/2022, 3:42 PMJosh Paulin
06/10/2022, 3:56 PMYehor Anisimov
06/10/2022, 4:42 PMFailed to load and execute flow run: KeyError('The secret ghp_pZdHbjkfhkjkefefiejfefnPd1VJikfn was not found. Please ensure that it was set correctly in your tenant: <https://docs.prefect.io/orchestration/concepts/secrets.html>')
I suppose issue in access_token_secret, I stored it in Cloud Secrets
STORAGE = GitHub(
repo="",
path=f"flows/{FLOW_NAME}.py",
access_token_secret=Secret('GITHUB_ACCESS_TOKEN').get()
)
I checked, github token is valid. Any ideas about this error?
Thank youaaron
06/10/2022, 5:17 PMAndreas Nigg
06/10/2022, 6:17 PMChristopher Haack
06/10/2022, 7:55 PMBoggdan Barrientos
06/10/2022, 8:31 PMParth Patel
06/10/2022, 9:42 PMYehor Anisimov
06/11/2022, 5:41 AM[2022-06-11 08:35:49+0300] ERROR - prefect.CloudTaskRunner | Task 'DbtShellTask': Exception encountered during task execution!
Traceback (most recent call last):
File "C:\Users\User\PycharmProjects\demo\venv\lib\site-packages\prefect\engine\task_runner.py", line 880, in get_task_run_state
value = prefect.utilities.executors.run_task_with_timeout(
File "C:\Users\User\PycharmProjects\demo\venv\lib\site-packages\prefect\utilities\executors.py", line 468, in run_task_with_timeout
return task.run(*args, **kwargs) # type: ignore
File "C:\Users\User\PycharmProjects\demo\venv\lib\site-packages\prefect\utilities\tasks.py", line 456, in method
return run_method(self, *args, **kwargs)
File "C:\Users\User\PycharmProjects\demo\venv\lib\site-packages\prefect\tasks\dbt\dbt.py", line 192, in run
return super(DbtShellTask, self).run(
File "C:\Users\User\PycharmProjects\demo\venv\lib\site-packages\prefect\utilities\tasks.py", line 456, in method
return run_method(self, *args, **kwargs)
File "C:\Users\User\PycharmProjects\demo\venv\lib\site-packages\prefect\tasks\shell.py", line 145, in run
line = raw_line.decode("utf-8").rstrip()
UnicodeDecodeError: 'utf-8' codec can't decode byte 0xad in position 7: invalid start byte
Any ideas what is the issue?Massimiliano Fanciulli
06/12/2022, 10:21 AMVolker L
06/12/2022, 11:06 AMmahmoud elhalwany
06/12/2022, 11:47 AMTraceback (most recent call last):
File "/Library/Frameworks/Python.framework/Versions/3.7/lib/python3.7/site-packages/prefect/cli/base.py", line 59, in wrapper
return fn(*args, **kwargs)
File "/Library/Frameworks/Python.framework/Versions/3.7/lib/python3.7/site-packages/prefect/utilities/asyncio.py", line 120, in wrapper
return run_async_in_new_loop(async_fn, *args, **kwargs)
File "/Library/Frameworks/Python.framework/Versions/3.7/lib/python3.7/site-packages/prefect/utilities/asyncio.py", line 67, in run_async_in_new_loop
return anyio.run(partial(__fn, *args, **kwargs))
File "/Library/Frameworks/Python.framework/Versions/3.7/lib/python3.7/site-packages/anyio/_core/_eventloop.py", line 56, in run
return asynclib.run(func, *args, **backend_options)
File "/Library/Frameworks/Python.framework/Versions/3.7/lib/python3.7/site-packages/anyio/_backends/_asyncio.py", line 233, in run
return native_run(wrapper(), debug=debug)
File "/Library/Frameworks/Python.framework/Versions/3.7/lib/python3.7/asyncio/runners.py", line 43, in run
return loop.run_until_complete(main)
File "/Library/Frameworks/Python.framework/Versions/3.7/lib/python3.7/asyncio/base_events.py", line 584, in run_until_complete
return future.result()
File "/Library/Frameworks/Python.framework/Versions/3.7/lib/python3.7/site-packages/anyio/_backends/_asyncio.py", line 228, in wrapper
return await func(*args)
File "/Library/Frameworks/Python.framework/Versions/3.7/lib/python3.7/site-packages/prefect/cli/base.py", line 162, in version
if is_ephemeral:
UnboundLocalError: local variable 'is_ephemeral' referenced before assignment
An exception occurred.