aviv
04/01/2024, 9:42 AM@task
def mytask():
task_name = prefect.get_task_name()
Jeff Hale
04/01/2024, 1:57 PMfrom prefect import flow, task
from prefect import runtime
@flow(log_prints=True)
def my_flow(x):
print("My name is", runtime.flow_run.name)
print("I belong to deployment", runtime.deployment.name)
my_task(2)
@task
def my_task(y):
print("My name is", runtime.task_run.name)
print("Flow run parameters:", runtime.flow_run.parameters)
my_flow(1)
aviv
04/01/2024, 2:08 PM