We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents ff4dbf9 + 693ac56 commit 96b0c94Copy full SHA for 96b0c94
1 file changed
automation/canfar_polling.py
@@ -111,7 +111,6 @@ async def _fetch_prefect_completed_flow_runs(limit: int = 200):
111
async def _fail_flow_run(flow_run_id, reason: str) -> None:
112
"""Mark the specified flow-run as FAILED with the given reason/message."""
113
async with get_client() as client:
114
- await client.cancel_flow_run(flow_run_id=flow_run_id)
115
await client.set_flow_run_state(
116
flow_run_id=flow_run_id,
117
state=Failed(message=reason),
0 commit comments