Michael Dymshits
12/20/2022, 12:51 PMpytest
which has perfect decorator
,
I got the following error (screenshot bellow).
If I comment #flow decorator, pytest runs without errors.Michael Dymshits
12/20/2022, 12:52 PMhkazmi
12/20/2022, 1:22 PM(401) Reason: Unauthorized HTTP response headers: HTTPHeaderDict({'Audit-Id': '', 'Cache-Control': 'no-cache, private', 'Content-Type': 'application/json', 'Date': 'Tue, 20 Dec 2022 13:00:03 GMT', 'Content-Length': '129'}) HTTP response body: {"kind":"Status","apiVersion":"v1","metadata":{},"status":"Failure","message":"Unauthorized","reason":"Unauthorized","code":401}
I have checked all keys and non of them is expired
What could be other possible reason for this error ?Harry Hause
12/20/2022, 3:05 PMMarcelo Santoro
12/20/2022, 3:13 PMVadym Dytyniak
12/20/2022, 3:14 PMMissi Sogbohossou
12/20/2022, 3:49 PMMissi Sogbohossou
12/20/2022, 3:49 PMMadison Schott
12/20/2022, 5:09 PM/usr/local/lib/python3.9/site-packages/prefect/core/flow.py:1726: UserWarning: No result handler was specified on your Flow. Cloud features such as input caching and resuming task runs from failure may not work properly.
Edmund Tian
12/20/2022, 5:29 PMOperationalError:
(sqlite3.OperationalError) no such table: flow_run_alert_policy
[SQL: ALTER TABLE flow_run_alert_policy RENAME TO flow_run_notification_policy]
(Background on this error at: <https://sqlalche.me/e/14/e3q8>)
I’m using the @flow
and @task
decorators for my Python functions. I’m not using Prefect Cloud. I’m on the following prefect version prefect==2.3.2
. It’s hard for me to repo because this occurs during my chron job, and it only occurs for a small subset of the Flow Runs. I haven’t been able to repo locally.
Anyone know what’s going on? A quick Google brought me to this, but this doesn’t seem related as I am not deploying anything and I’m not using orion
.Patrick Tan
12/20/2022, 6:57 PMPatrick Tan
12/20/2022, 7:09 PMPatrick Tan
12/20/2022, 7:13 PMAmruth VVKP
12/20/2022, 8:08 PMSanthosh Solomon (Fluffy)
12/20/2022, 9:35 PMAdam Roderick
12/20/2022, 10:41 PM.fetchall()
which isn't usable for large datasets. Any other attempts we've done to use similar logic but using a cursor fails. What is it about the prefect execution environment that prevents us from using snowflake cursors?Samuel Hinton
12/21/2022, 2:04 AMNiwde Nus
12/21/2022, 2:39 AMGows Shaik
12/21/2022, 5:38 AMGows Shaik
12/21/2022, 5:40 AMMalavika S Menon
12/21/2022, 6:06 AMDeepanshu Aggarwal
12/21/2022, 6:35 AMFlow run infrastructure exited with non-zero status code -1.
no extra logs nothing, it also leaves the tasks in running state. any idea why this happens ?YD
12/21/2022, 7:41 AM'state_handlers': [o.p_state_handler]
which sent me an SMS alert on task failure.
how can i achieve this kind of behavior in Prefect 2.0?
thanksYD
12/21/2022, 7:51 AM@task(timeout_seconds=1)
but I get an error: TypeError: task() got an unexpected keyword argument 'timeout_seconds'
What is the proper way to set a timeout time for tasks in Prefect 2 ?Kelvin DeCosta
12/21/2022, 9:31 AMtask
is configured with cache_result_in_memory=False
, can its result only be consumed via state.result()
/ future.result()
?
Calling such tasks directly, i.e.. result = my_task()
, seems to raise the MissingResult
error.Mark Nuttall-Smith
12/21/2022, 9:48 AMmyapp
docker container for execution.Aleksandr Liadov
12/21/2022, 11:15 AMJaime Raldua Veuthey
12/21/2022, 11:32 AMAlexandru Anghel
12/21/2022, 1:58 PMCrash detected! Execution was interrupted by an unexpected exception: AttributeError: 'KubeCluster' object has no attribute '__qualname__'
For more context, i'll add some code in the thread.
Thanks!Michał
12/21/2022, 2:24 PMFor more information check: <https://httpstatuses.com/422>
15:18:47.351 | INFO | prefect.agent - Completed submission of flow run '5adc8699-d9a5-4042-85d0-0b072a4873d0'
<frozen runpy>:128: RuntimeWarning: 'prefect.engine' found in sys.modules after import of package 'prefect', but prior to execution of 'prefect.engine'; this may result in unpredictable behaviour
15:18:48.970 | INFO | Flow run 'fantastic-tamarin' - Hello from demo-flow!
15:18:48.995 | ERROR | Flow run 'fantastic-tamarin' - Crash detected! Execution was interrupted by an unexpected exception: httpx.HTTPStatusError: Client error '422 Unprocessable Entity' for url 'http://prefect-server:4200/api/flow_runs/5adc8699-d9a5-4042-85d0-0b072a4873d0/set_state'Michał
12/21/2022, 2:24 PMFor more information check: <https://httpstatuses.com/422>
15:18:47.351 | INFO | prefect.agent - Completed submission of flow run '5adc8699-d9a5-4042-85d0-0b072a4873d0'
<frozen runpy>:128: RuntimeWarning: 'prefect.engine' found in sys.modules after import of package 'prefect', but prior to execution of 'prefect.engine'; this may result in unpredictable behaviour
15:18:48.970 | INFO | Flow run 'fantastic-tamarin' - Hello from demo-flow!
15:18:48.995 | ERROR | Flow run 'fantastic-tamarin' - Crash detected! Execution was interrupted by an unexpected exception: httpx.HTTPStatusError: Client error '422 Unprocessable Entity' for url 'http://prefect-server:4200/api/flow_runs/5adc8699-d9a5-4042-85d0-0b072a4873d0/set_state'Khuyen Tran
12/21/2022, 5:17 PMMichał
12/21/2022, 5:18 PMcurl -X 'GET' \
'<http://prefect-server:14200/api/admin/version>' \
-H 'accept: application/json'
I found that even I use tag 2,7.3 i get version 2.4.5 in this endpoint when I downgraded my local prefect version from agent from 2.7.3 to 2.4.5 flows works and I don't get this 422 error. But when I got back to version 2.7.3 error is back.Tibs
01/09/2023, 3:11 PMTaylor Curran
01/09/2023, 5:39 PM