Hi everyone! I encountered an error when attempting to restart a flow from the failed task and was wondering if anyone has some best practices on how to handle this? Context: • I have a "Flow of Flows" that triggers a few connectors from Fivetran in parallel then triggers a dbt job run for the data modelling for the source once the data has finished syncing • There is one dbt job that is then run after all the prior dbt jobs have succeeded (this is the one that failed in this instance) • After fixing the error, when I press restart I get an error saying ◦ This then returns a list of all the flow runs on this flow id Question: • What would I need to specify in the task parameter so that it only re-runs the latest flow when I press restart on the UI? Thank you so much in advance for your time and help! 😄

Hi @Tanasorn Chindasook, could you move the error to the thread when you get a chance so we dont crowd the main channel? In Prefect 1, it’s hard to restart a failed child flow run. See the full writeup here. Are you restarting the subflow and then running this wait? How did you fix the error? Because you needed to re-register right? I’m not sure you can re-run an archived flow.

Edited to move error to the thread!

Task 'wait_for_flow_run': Exception encountered during task execution!
Traceback (most recent call last):
  File "/usr/local/lib/python3.7/site-packages/prefect/engine/task_runner.py", line 884, in get_task_run_state
    logger=self.logger,
  File "/usr/local/lib/python3.7/site-packages/prefect/utilities/executors.py", line 468, in run_task_with_timeout
    return task.run(*args, **kwargs)  # type: ignore
  File "/usr/local/lib/python3.7/site-packages/prefect/tasks/prefect/flow_run.py", line 264, in wait_for_flow_run
    flow_run = FlowRunView.from_flow_run_id(flow_run_id)
  File "/usr/local/lib/python3.7/site-packages/prefect/backend/flow_run.py", line 571, in from_flow_run_id
    flow_run_data = cls._query_for_flow_run(where={"id": {"_eq": flow_run_id}})
  File "/usr/local/lib/python3.7/site-packages/prefect/backend/flow_run.py", line 629, in _query_for_flow_run
    f"Found multiple ({len(flow_runs)}) flow runs while querying for flow "
ValueError: Found multiple (134) flow runs while querying for flow runs

@Tanasorn Chindasook are you good now?