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