Revision 2904
Added by Aaron Marcuse-Kubitza about 12 years ago
lib/sql.py | ||
---|---|---|
1261 | 1261 |
insert_out_pkeys = insert_pkeys_table('out') |
1262 | 1262 |
insert_in_pkeys = insert_pkeys_table('in') |
1263 | 1263 |
|
1264 |
log_debug('Locking output tables to prevent concurrent duplicate keys') |
|
1265 |
for table in [out_table, errors_table_]: lock_table(db, table, 'EXCLUSIVE') |
|
1266 |
|
|
1267 | 1264 |
# Do inserts and selects |
1268 | 1265 |
join_cols = sql_gen.ColDict(db, out_table) |
1269 | 1266 |
while True: |
Also available in: Unified diff
sql.py: put_table(): Removed locking output tables to prevent concurrent duplicate keys because that is now done automatically by mk_select()