Hi I m trying to get a flow to show as cancelled in the UI s

Question

Hi I m trying to get a flow to show as cancelled in the UI so have used `from prefect server schemas states import Completed Failed Cancelled` with `return Cancelled message= No records retreived ` in my code somewhere This still shows as Failed though with the cancelled being part of the failed message `10 43 06 764 | ERROR | Flow run astonishing hawk Finished in state Failed Flow run encountered an exception CancelledRun No records retreived ` Any idea if I m missing something or if there s a better way

Ash · Answer

Full message `10 43 06 764 | ERROR | Flow run astonishing hawk Finished in state Failed Flow run encountered an exception CancelledRun No records retreived ` `Traceback most recent call last ` `File root flows projects inmotion questions inmotion questions etl py line 206 in lt module gt ` `etl questions data ` `File usr local lib python3 11 site packages prefect flows py line 511 in call ` `return enter flow run engine from flow call ` `^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^` `File usr local lib python3 11 site packages prefect engine py line 272 in enter flow run engine from flow call` `retval = from sync wait for call in loop thread ` `^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^` `File usr local lib python3 11 site packages prefect internal concurrency api py line 243 in wait for call in loop thread` `return call result ` `^^^^^^^^^^^^^` `File usr local lib python3 11 site packages prefect internal concurrency calls py line 283 in result` `return self future result timeout=timeout ` `^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^` `File usr local lib python3 11 site packages prefect internal concurrency calls py line 169 in result` `return self get result ` `^^^^^^^^^^^^^^^^^^^` `File usr local lib python3 11 concurrent futures base py line 401 in get result` `raise self exception` `File usr local lib python3 11 site packages prefect internal concurrency calls py line 346 in run async` `result = await coro` `^^^^^^^^^^` `File usr local lib python3 11 site packages prefect client utilities py line 51 in with injected client` `return await fn args kwargs ` `^^^^^^^^^^^^^^^^^^^^^^^^^` `File usr local lib python3 11 site packages prefect engine py line 375 in create then begin flow run` `return await state result fetch=True ` `^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^` `File usr local lib python3 11 site packages prefect states py line 91 in get state result` `raise await get state exception state ` `File usr local lib python3 11 site packages prefect engine py line 833 in orchestrate flow run` `result = await flow call aresult ` `^^^^^^^^^^^^^^^^^^^^^^^^^` `File usr local lib python3 11 site packages prefect internal concurrency calls py line 292 in aresult` `return await asyncio wrap future self future ` `^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^` `File usr local lib python3 11 site packages prefect internal concurrency calls py line 316 in run sync` `result = self fn self args self kwargs ` `^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^` `File root flows projects inmotion questions inmotion questions etl py line 24 in etl questions data` `questions data = extract questions url maximum question id ` `^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^` `File usr local lib python3 11 site packages prefect tasks py line 505 in call ` `return enter task run engine ` `^^^^^^^^^^^^^^^^^^^^^^` `File usr local lib python3 11 site packages prefect engine py line 1137 in enter task run engine` `return from sync wait for call in loop thread begin run ` `^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^` `File usr local lib python3 11 site packages prefect internal concurrency api py line 243 in wait for call in loop thread` `return call result ` `^^^^^^^^^^^^^` `File usr local lib python3 11 site packages prefect internal concurrency calls py line 283 in result` `return self future result timeout=timeout ` `^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^` `File usr local lib python3 11 site packages prefect internal concurrency calls py line 169 in result` `return self get result ` `^^^^^^^^^^^^^^^^^^^` `File usr local lib python3 11 concurrent futures base py line 401 in get result` `raise self exception` `File usr local lib python3 11 site packages prefect internal concurrency calls py line 346 in run async` `result = await coro` `^^^^^^^^^^` `File usr local lib python3 11 site packages prefect engine py line 1302 in get task call return value` `return await future result ` `^^^^^^^^^^^^^^^^^^^^^^` `File usr local lib python3 11 site packages prefect futures py line 237 in result` `return await final state result raise on failure=raise on failure fetch=True ` `^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^` `File usr local lib python3 11 site packages prefect states py line 91 in get state result` `raise await get state exception state ` `prefect exceptions CancelledRun No records retreived `

Jake Kaplan · Answer

You should be able to do this ```from prefect import flow from prefect states import Cancelled flow def my flow return Cancelled message= The flow is cancelled if name == main my flow ``` gives ```09 47 13 652 | ERROR | Flow run hypersonic honeybee Finished in state Cancelled The flow is cancelled prefect exceptions CancelledRun The flow is cancelled```

Jake Kaplan · Answer

are you running your flow differently or with an option maybe

Ash · Answer

Ah so the cancelled part has to go in the flow itself mine was in a task

Ash · Answer

Is there a way to trigger a cancel from a task or is it a case of having to pass back something to the flow to tell it to cancel it there

Jake Kaplan · Answer

You could do something like this ```from prefect import flow task from prefect states import Cancelled task def my task return Cancelled message= The task is cancelled flow def my flow state = my task return state=True if state is cancelled return Cancelled message= The flow is cancelled if name == main my flow ```

Jake Kaplan · Answer

traditionally cancelled means something a little different where the flow run is cancelled first not the task

Ash · Answer

Thanks < Jake Kaplan> I will look into this I was attempting to cancel the rest of the flow and tasks if one of the prelim tasks fails

Jake Kaplan · Answer

np Do you need it to be `Cancelled` specifically Normally prefect treats things like that as failed ``` task def my task raise Exception didn t work flow def my flow my task ```

Ash · Answer

It s more for the Prefect UI to show that something tried to run but didn t because there was nothing new to process so Cancelled makes it a bit clearer when looking in the history Failed makes it seem like something went wrong slightly smiling face

Jake Kaplan · Answer

Ah I see makes sense You might find this useful potentially <https github com PrefectHQ prefect issues 10291 issuecomment 1682350743> best of luck

Ash · Answer

Oooo that looks even better thank you