https://prefect.io
Join Slack
hey, I tried to register a new version of a flow while the previous was running and it failed the ru...
# ask-community
p
hey, 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'}}
It 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
Hey @Patrick Valencio Leguizamon, I’ll have to look more into this today
p
ok, thanks
k
What Prefect version are you on? Having a hard time replicating this
p
it is 0.15.1 withou idempotency key
k
How are you running? The CLI with agentless execution?
p
no, it was registered in cloud with kubernetes agent
k
And then you hit the Quick Run in the UI or was this a scheduled run?
p
it was a scheduled run
k
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
yes, I'm using the wait_for_flow_run
6 Views
Open in Slack
PreviousNext
Powered by

Prefect Community

Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.

Powered by