Sanjay Patel
04/29/2020, 1:08 AMsimids = [1, 2, 3]
with Flow('example') as flow:
x = task1.map(simids)
y = task2.map(x)
z = task3.map(x, y)
#start a DB session
write_session = create_db_session.map()
task_write_to_db.map(write_session, x , z)
#summarize task - after completion of all mapped results - this part executes too early before all mapped tasks are complete
read_session = create_db_session()
PostProcessResults()
nicholas
04/29/2020, 1:15 AMsimids = [1, 2, 3]
with Flow('example') as flow:
x = task1.map(simids)
y = task2.map(x)
z = task3.map(x, y)
#start a DB session
write_session = create_db_session.map()
task_write_to_db.map(write_session, x , z)
#summarize task - after completion of all mapped results - this part executes too early before all mapped tasks are complete
read_session = create_db_session()
PostProcessResults(upstream_tasks=[x, y, z])
Sanjay Patel
04/29/2020, 2:18 AMnicholas
04/29/2020, 2:27 AM