haven
08/10/2021, 7:12 AMfrom prefect import context as prefect_context, task
@task
def enrich_context():
prefect_context["custom_key"] = 1
@task
def main_task():
value = prefect_context["custom_key"]
print(value)
with Flow("test-enrich_context") as flow:
_enrich_context_task = enrich_context()
main_task(upstream_tasks=[_enrich_context_task])
Kevin Kho
haven
08/10/2021, 7:17 AMKevin Kho