Revision 3669
Added by Aaron Marcuse-Kubitza over 12 years ago
bin/map | ||
---|---|---|
273 | 273 |
if id_node == None: |
274 | 274 |
warnings.warn(UserWarning('Map warning: No mappings')) |
275 | 275 |
sys.stdout.write('Put template:\n'+str(root)) |
276 |
sys.stdout.flush() |
|
276 | 277 |
|
277 | 278 |
def process_row(row, i): |
278 | 279 |
row_id = str(i) |
... | ... | |
444 | 445 |
row_ct = process_inputs(root, row_ready) |
445 | 446 |
sys.stdout.write('Inserted '+str(row_ins_ct_ref[0])+ |
446 | 447 |
' new rows into database\n') |
448 |
sys.stdout.flush() |
|
447 | 449 |
|
448 | 450 |
# Consume asynchronous tasks |
449 | 451 |
pool.main_loop() |
Also available in: Unified diff
bin/map: Call sys.stdout.flush() after every call to sys.stdout.write() to avoid interleaved stdout/stderr output due to stdout buffering