search

NCATS-Tangerine / ros

1 stars 1 forks source link

Concurrent Task Execution #7

Closed stevencox closed 6 years ago

stevencox commented 6 years ago

Develop a parallel execution model.

stevencox commented 6 years ago

Should probably change this once 3.7 is stable: 


                    task = asyncio.ensure_future (exec_async (self.workflow, j))
                    self.workflow.execution.running[j] = task
                    topsort_rec.remove (j)
                    await task