Patrick Valencio Leguizamon

    Patrick Valencio Leguizamon

    1 year ago
    hey, I tried to register a new version of a flow while the previous was running and it failed the run with an error
    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
    [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"
    Kevin Kho

    Kevin Kho

    1 year ago
    Hey @Patrick Valencio Leguizamon, I’ll have to look more into this today
    Patrick Valencio Leguizamon

    Patrick Valencio Leguizamon

    1 year ago
    ok, thanks
    Kevin Kho

    Kevin Kho

    1 year ago
    What Prefect version are you on? Having a hard time replicating this
    Patrick Valencio Leguizamon

    Patrick Valencio Leguizamon

    1 year ago
    it is 0.15.1 withou idempotency key
    Kevin Kho

    Kevin Kho

    1 year ago
    How are you running? The CLI with agentless execution?
    Patrick Valencio Leguizamon

    Patrick Valencio Leguizamon

    1 year ago
    no, it was registered in cloud with kubernetes agent
    Kevin Kho

    Kevin Kho

    1 year ago
    And then you hit the Quick Run in the UI or was this a scheduled run?
    Patrick Valencio Leguizamon

    Patrick Valencio Leguizamon

    1 year ago
    it was a scheduled run
    Kevin Kho

    Kevin Kho

    1 year ago
    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.
    Patrick Valencio Leguizamon

    Patrick Valencio Leguizamon

    1 year ago
    yes, I'm using the wait_for_flow_run