Muddassir Shaikh
01/19/2022, 5:35 PMKevin Kho
Muddassir Shaikh
01/19/2022, 6:50 PMKevin Kho
Muddassir Shaikh
01/19/2022, 6:55 PMleft_branch = processing.map(processing_channels([('some_var1', date)]))
right_branch = processing.map(processing_channels([('some_var2', date)]))
Kevin Kho
LocalDaskExecutor(scheduler="processes")
Muddassir Shaikh
01/19/2022, 6:57 PMflow.executor = LocalDaskExecutor()
Kevin Kho
Muddassir Shaikh
01/19/2022, 6:58 PMKevin Kho
Muddassir Shaikh
01/19/2022, 7:02 PMKevin Kho
Muddassir Shaikh
01/20/2022, 4:41 PMKevin Kho
Muddassir Shaikh
01/20/2022, 4:46 PM