Chris K.
01/22/2022, 4:26 PMAn executor that runs all functions synchronously and immediately in the main thread. To be used mainly for debugging purposes.
flow.executor = LocalDaskExecutor(scheduler="threads", num_workers=1)
Kevin Kho
Chris K.
01/22/2022, 4:46 PMKevin Kho
Chris K.
01/22/2022, 4:52 PMKevin Kho
Chris K.
01/22/2022, 4:55 PMKevin Kho
Chris K.
01/22/2022, 7:07 PM`start_time (datetime)`: time at which the task is scheduled to resume; defaults to 10 years from now if not provided.
Kevin Kho