Aleksandr Liadov
12/15/2022, 10:16 AMgraph = {
"feature_1" : [],
"feature_2" : [],
"feature_3" : ["feature_1", "feature_2"],
"feature_4" : ["feature_3"],
"feature_5" : ["feature_4"],
}
So how can I “explain” that in the first time we can run in parallel feature_1
and feature_2
, but not the others one.
We can run feature_3
, only when feature_1
and feature_2
was successfully executed, and feature_3 take like input parameters the results of feature_1
and feature_2
.
P.S. In production it should be run with DaskTaskRunner
. Could be there any difficulty?Aleksandr Liadov
12/15/2022, 5:09 PMprefect.tasks.Task object
instead of PrefectFuture
:(Khuyen Tran
12/16/2022, 4:56 PMwait_for
and submit
to your code?Aleksandr Liadov
12/21/2022, 4:40 PM