In [1]: from prefect import flow, get_client
In [2]: from prefect.context import get_run_context
...:
...: @flow
...: async def f():
...: async with get_client() as client:
...: await client.update_flow_run(get_run_context().flow_run.id, tags=['asdf'])
...:
In [3]: await f()
10:46:57.357 | INFO | prefect.engine - Created flow run 'gregarious-capybara' for flow 'f'
10:46:58.010 | INFO | Flow run 'gregarious-capybara' - Finished in state Completed()
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.