Workflow that does not block.

[drewoldag]

A workflow that doesn't block later execution by waiting for all instances of prior tasks to complete.

To run this locally, have parsl installed and from the top level source directory run:

>> python ./src/kbmod_wf/simple_workflow.py --env=dev 

#Expected output:
Starting workflow
Step 1: key: ants, slept: 4
Step 1: key: bees, slept: 3
Step 1: key: elephants, slept: 2
Step 1: key: frogs, slept: 1
Step 2: key: ants.txt
Step 2: key: bees.txt
Step 2: key: elephants.txt
Step 1: key: dogs, slept: 14
Step 2: key: frogs.txt
Step 1: key: cats, slept: 15
Step 2: key: dogs.txt
Step 2: key: cats.txt
Workflow complete

[drewoldag]

The magic happens on lines 28 and 72.

Note that in the for loop, we're not calling f.result(), but instead simply f. And in the task definition, we're calling inputs[0].filepath.

[wilsonbb]

LGTM!