Newskooler
10/01/2020, 9:04 PM{
"strings": ['string1', 'string2'],
'start_date': '20200920',
'end_date': '20200930',
}
nicholas
Newskooler
10/01/2020, 9:10 PMnicholas
Newskooler
10/01/2020, 9:14 PMnicholas
from prefect.engine.executors import LocalDaskExecutor
# other stuff
flow.environment = LocalEnvironment(
labels=[], executor=LocalDaskExecutor(scheduler="threads", num_workers=6),
)
Newskooler
10/01/2020, 9:17 PMLocalDaskExecutor
and DaskExecutor
, why is that?nicholas
Newskooler
10/01/2020, 9:29 PM