E Li
02/09/2022, 8:33 PMKevin Kho
E Li
02/09/2022, 8:34 PMKevin Kho
E Li
02/09/2022, 8:45 PMWith Flow() as flow:
# inputs is a list
Output = taskA_and_taskB.map(inputs, unmapped(prop))
@task()
Def taskA_and_taskB(input, prop):
outputA = taskA(input, prop)
outputB = taskB(outputA, prop)Kevin Kho
with Flow(...) as flow:
a = task_a.map(inputs)
task_b.map(a)
If your setup if like this, it will execute in a depth first way and then is B fails and you retry, the target from a should be retrieved for it. Or am I missing something?E Li
02/09/2022, 8:57 PMKevin Kho
E Li
02/09/2022, 9:00 PMKevin Kho
args
here . I present to you the least known Prefect feature lolE Li
02/09/2022, 9:31 PM@task(tags="dask-resource:index=1")
?Kevin Kho
E Li
02/09/2022, 9:42 PMKevin Kho
checkpoint=False
inside the task? This is for a run with an agent right?E Li
02/14/2022, 5:45 PMKevin Kho
export PREFECT__FLOWS__CHECKPOINTING=true
should workE Li
02/14/2022, 6:16 PM