hey, I tried to register a new version of a flow w...
# ask-communityp
Patrick Valencio Leguizamon
09/08/2021, 1:36 PMhey, I tried to register a new version of a flow while the previous was running and it failed the run with an error
Copy code
Traceback (most recent call last):
File "/usr/local/lib/python3.8/site-packages/prefect/engine/task_runner.py", line 861, in get_task_run_state
value = prefect.utilities.executors.run_task_with_timeout(
File "/usr/local/lib/python3.8/site-packages/prefect/utilities/executors.py", line 327, in run_task_with_timeout
return task.run(*args, **kwargs) # type: ignore
File "/usr/local/lib/python3.8/site-packages/prefect/tasks/prefect/flow_run.py", line 235, in wait_for_flow_run
for log in watch_flow_run(
File "/usr/local/lib/python3.8/site-packages/prefect/backend/flow_run.py", line 94, in watch_flow_run
flow_run = flow_run.get_latest()
File "/usr/local/lib/python3.8/site-packages/prefect/backend/flow_run.py", line 422, in get_latest
return self.from_flow_run_id(
File "/usr/local/lib/python3.8/site-packages/prefect/backend/flow_run.py", line 568, in from_flow_run_id
flow_run_data = cls._query_for_flow_run(where={"id": {"_eq": flow_run_id}})
File "/usr/local/lib/python3.8/site-packages/prefect/backend/flow_run.py", line 620, in _query_for_flow_run
raise ValueError(
ValueError: No flow runs found while querying for flow runs where {'id': {'_eq': 'b1533b47-859e-46c7-acdc-dbe4976ac3e7'}}Patrick Valencio Leguizamon
09/08/2021, 1:42 PMIt was running with kubernetes and the pod started to loop with this error
Copy code
[2021-09-08 13:26:50+0000] WARNING - prefect.CloudFlowRunner | Error getting flow run info
Traceback (most recent call last):
File "/usr/local/lib/python3.8/site-packages/prefect/engine/cloud/flow_runner.py", line 188, in interrupt_if_cancelling
flow_run_info = self.client.get_flow_run_info(flow_run_id)
File "/usr/local/lib/python3.8/site-packages/prefect/client/client.py", line 1471, in get_flow_run_info
raise ClientError('Flow run ID not found: "{}"'.format(flow_run_id))
prefect.exceptions.ClientError: Flow run ID not found: "b1533b47-859e-46c7-acdc-dbe4976ac3e7"k
Kevin Kho
09/08/2021, 2:40 PM
Hey @Patrick Valencio Leguizamon, I’ll have to look more into this today
p
Patrick Valencio Leguizamon
09/08/2021, 2:49 PMok, thanks
k
Kevin Kho
09/08/2021, 4:13 PM
What Prefect version are you on? Having a hard time replicating this
p
Patrick Valencio Leguizamon
09/08/2021, 6:42 PMit is 0.15.1 withou idempotency key
k
Kevin Kho
09/08/2021, 6:52 PM
How are you running? The CLI with agentless execution?
p
Patrick Valencio Leguizamon
09/08/2021, 7:05 PMno, it was registered in cloud with kubernetes agent
k
Kevin Kho
09/08/2021, 7:10 PM
And then you hit the Quick Run in the UI or was this a scheduled run?
p
Patrick Valencio Leguizamon
09/08/2021, 7:11 PMit was a scheduled run
k
Kevin Kho
09/08/2021, 8:42 PM
Hey, I think the issue here is that you have a specific task that is failing (create_flow_run or wait_for_flow_run) because of the edit. Are you using tasks like this? I believe this is related to this other issue so I will add what you are experiencing here.
p
Patrick Valencio Leguizamon
09/09/2021, 1:37 PMyes, I'm using the wait_for_flow_run
7 Views