Geert-Jan Van den Bogaerde
04/14/2022, 3:13 PMKevin Kho
04/14/2022, 3:18 PMGeert-Jan Van den Bogaerde
04/14/2022, 3:27 PM@task
def get_current_flow_run_labels():
logger = prefect.context.get('logger')
flow_run_id = prefect.context.get("flow_run_id")
flow_run_view = FlowRunView.from_flow_run_id(flow_run_id)
labels = flow_run_view.labels
<http://logger.info|logger.info>(f"Labels: {labels}")
return labels
Kevin Kho
04/14/2022, 3:28 PMGeert-Jan Van den Bogaerde
04/14/2022, 3:35 PMKevin Kho
04/14/2022, 3:36 PMGeert-Jan Van den Bogaerde
04/14/2022, 3:53 PMKevin Kho
04/14/2022, 3:59 PMAnna Geller
04/14/2022, 4:13 PM@task
๐Geert-Jan Van den Bogaerde
04/14/2022, 6:08 PM@flow
;-)Anna Geller
04/14/2022, 6:10 PM