If the task is cancelled, why does the parent flow is failed? I'm cancelling my task by returning Cancelled state when a condition is met.

return Cancelled(message="User requested task cancellation!")

hi @Shahid Khan is this prefect 2.x or 3.x?

Prefect 3

i don't think you need to use the client directly

#[7]
from prefect import flow, task

#[8]
@task
def foo():
    pass


#[9]
@flow
def f():
    foo.with_options(tags=["asdf"])()


#[10]
f()
15:22:23.784 | INFO    | Flow run 'golden-dalmatian' - Beginning flow run 'golden-dalmatian' for flow 'f'
15:22:23.786 | INFO    | Flow run 'golden-dalmatian' - View at <http://localhost:4200/runs/flow-run/b2944caf-12cf-4de7-ba3b-77466be290de>
15:22:23.849 | INFO    | Task run 'foo-a38' - Finished in state Completed()
15:22:23.868 | INFO    | Flow run 'golden-dalmatian' - Finished in state Completed()

Thanks @Nate for the response. I've tried this but this does not fulfill my needs. I'm trying to update tag inside the task function on the condition of it being successful or not. For example, if alerts are generated inside task, I'm planning to tag

alert_status:found

, so that I can filter task with this tag and get the idea of number of alerts being generated. Is there any way to update the tags for the task inside the function in Prefect 3?

I would say this is a pretty atypical pattern, I would personally reach for a named state before updating tags on a task from within, but if you really need to do the latter then i would do it in a state hook like an on failure state hook

Thanks a lot Nate, I'll give this a try. Cheers for Prefect community.