Ilya Galperin
09/22/2022, 7:02 PMNate
09/22/2022, 7:14 PMIlya Galperin
09/22/2022, 7:21 PM@flow(name="example_flow")
we would want to find the value example_flow
Nate
09/22/2022, 7:34 PMfrom prefect import flow, get_run_logger, task
@task
def log_flow_name():
logger = get_run_logger()
<http://logger.info|logger.info>(f"I'm task that makes up a flow `{test.__name__}` with name: {test.name}")
@flow(name="example_flow")
def test():
log_flow_name()
if __name__ == "__main__":
test()
❯ python flow_name.py
14:35:56.653 | INFO | prefect.engine - Created flow run 'tourmaline-shark' for flow 'example_flow'
14:35:57.304 | INFO | Flow run 'tourmaline-shark' - Created task run 'log_flow_name-96b8f2ed-0' for task 'log_flow_name'
14:35:57.306 | INFO | Flow run 'tourmaline-shark' - Executing 'log_flow_name-96b8f2ed-0' immediately...
14:35:57.469 | INFO | Task run 'log_flow_name-96b8f2ed-0' - I'm task that makes up a flow test with name: example_flow
14:35:57.556 | INFO | Task run 'log_flow_name-96b8f2ed-0' - Finished in state Completed()
14:35:57.651 | INFO | Flow run 'tourmaline-shark' - Finished in state Completed('All states completed.')
Ilya Galperin
09/22/2022, 9:25 PMNate
09/22/2022, 9:36 PMIlya Galperin
09/22/2022, 9:37 PM