Revision 2166
Added by Aaron Marcuse-Kubitza over 12 years ago
| map | ||
|---|---|---|
| 397 | 397 |
# Consume asynchronous tasks |
| 398 | 398 |
pool.main_loop() |
| 399 | 399 |
finally: |
| 400 |
out_db.db.rollback() |
|
| 401 |
out_db.db.close() |
|
| 400 |
if out_db.connected(): |
|
| 401 |
out_db.db.rollback() |
|
| 402 |
out_db.db.close() |
|
| 402 | 403 |
else: |
| 403 | 404 |
def on_error(e): ex_tracker.track(e) |
| 404 | 405 |
def row_ready(row_num, input_row): pass |
Also available in: Unified diff
bin/map: out_is_db: Only rollback() and close() out_db if it was connected