Argemiro Neto
09/19/2019, 12:04 AMtasks
inside tasks
and flows
inside tasks
? I was able to call a flow
inside a task but got a ValueError: Could not infer an active Flow context
error every time I tried to send parameters to the flows
from the tasks
. Got the same error when calling a task
within a task
.Chris White
09/19/2019, 12:05 AMArgemiro Neto
09/19/2019, 12:24 AMflow
and then call that from a task
Chris White
09/19/2019, 12:31 AMflow.update
for easily combining multiple flows into one Flow: https://docs.prefect.io/api/unreleased/core/flow.html#prefect-core-flow-flow-updateArgemiro Neto
09/19/2019, 12:47 AMupdate
function. I need to map the task results in a sequence of tasks with data dependency (flow like) between them. This sequence should run independently of each other. At this point, I'm running the first flow, checking the results outside prefect
and then running a loop with second_flow.run()
for each item. Is there a way to dynamically import tasks from a flow setting the Paramters
or a better way than mixing prefect
with raw python?Chris White
09/20/2019, 12:50 AMArgemiro Neto
09/20/2019, 6:57 PMtasks
on all the items, like, updating timestamp
.
3. The application should stop if #1 or #2 fails.
4. Run a series of tasks on each activity from #2. If one of the tasks from one activity fails it should not fail the other activities' tasks.