Philip MacMenamin
08/26/2022, 5:05 PMcontext
value on a per run basis?Mason Menges
08/26/2022, 7:13 PMPhilip MacMenamin
08/26/2022, 7:20 PM@task
def my_task_2(i: int) -> Tuple[int, int]:
# read something from context
fp = context.fp
do_thing(fp)
return (1, 2)
@task
def my_task() -> Tuple[int, int]:
# assign something to context
prefect.context.fp="/tmp/blah"
return (1, 2)
with Flow("flow_run_name") as f:
a, b = my_task()
my_task_2(a)
Parameter
that's passed into the flow on a per run basis) in an initial task of a workflow that will downstream tasks to get that value, if needed.Mason Menges
08/26/2022, 7:36 PMfrom prefect import Flow, task, config
@task
def foo(x: int):
config["test_key"] = "somval"
@task
def bar():
print(config["test_key"])
with Flow('test-config') as flow:
foo()
bar()
flow.run()
Philip MacMenamin
08/26/2022, 7:40 PMconfig
. OK, yup, this does what I want. Thank you.Mason Menges
08/26/2022, 7:41 PM