Revision 2927
Added by Aaron Marcuse-Kubitza over 12 years ago
| map | ||
|---|---|---|
| 430 | 430 |
# Consume asynchronous tasks |
| 431 | 431 |
pool.main_loop() |
| 432 | 432 |
finally: |
| 433 |
if out_db.connected(): |
|
| 434 |
out_db.db.rollback() |
|
| 435 |
out_db.db.close() |
|
| 433 |
if out_db.connected(): out_db.db.close() |
|
| 436 | 434 |
else: |
| 437 | 435 |
def on_error(e): ex_tracker.track(e) |
| 438 | 436 |
def row_ready(row_num, input_row): pass |
Also available in: Unified diff
bin/map: Removed rollback() call before closing the connection because PostgreSQL does this automatically