Anish Chhaparwal
10/08/2020, 1:59 PMDylan
Anish Chhaparwal
10/08/2020, 2:08 PMDylan
query_result_list
?Flow
definition, something like:
with Flow(name="My Flow", environment=LocalEnvironment(executor=DaskExecutor()) as flow:
# flow things
flow.run()
by default, but are used when a flow run is started by an agent if you’ve configured your flow as above ☝️Anish Chhaparwal
10/08/2020, 2:19 PMDylan
dcmpath_check
a task and use Prefect’s built-in mapppingAnish Chhaparwal
10/08/2020, 2:30 PMDylan
n_proc
or n_thread
depending on how you’re running your schedulerAnish Chhaparwal
10/08/2020, 2:35 PMDylan
Anish Chhaparwal
10/08/2020, 3:44 PMDylan
Anish Chhaparwal
10/08/2020, 3:47 PMDylan
Anish Chhaparwal
10/08/2020, 3:51 PMDylan
__main__
(this is one of the issues cloudpickle solves for)Anish Chhaparwal
10/08/2020, 4:08 PMDylan