Revision 1868
Added by Aaron Marcuse-Kubitza about 12 years ago
| map | ||
|---|---|---|
| 312 | 312 |
row_ct = process_inputs(root, row_ready) |
| 313 | 313 |
sys.stdout.write('Inserted '+str(row_ins_ct_ref[0])+
|
| 314 | 314 |
' new rows into database\n') |
| 315 |
|
|
| 316 |
# Consume asynchronous tasks |
|
| 317 |
pool.main_loop() |
|
| 315 | 318 |
finally: |
| 316 | 319 |
out_db.db.rollback() |
| 317 | 320 |
out_db.db.close() |
| ... | ... | |
| 325 | 328 |
else: # output is CSV |
| 326 | 329 |
raise NotImplementedError('CSV output not supported yet')
|
| 327 | 330 |
|
| 328 |
# Parallel processing
|
|
| 331 |
# Consume any asynchronous tasks not already consumed above
|
|
| 329 | 332 |
pool.main_loop() |
| 330 | 333 |
|
| 331 | 334 |
profiler.stop(row_ct) |
Also available in: Unified diff
bin/map: Also consume asynchronous tasks before closing the DB connection (this is where most if not all tasks will be consumed)