aviv
@task def mytask(): task_name = prefect.get_task_name()
Jeff Hale
from 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)
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.