diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-04-04 21:05:09 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-04-04 21:05:09 +0200 |
| commit | 9567fcbd4d41f603fab53864008add884bd315de (patch) | |
| tree | d86ad752a265365a5a9d052b20fcb8ba96335788 | |
| parent | 7d085bac26ca372a3c9bd097f7c7214af5fbb408 (diff) | |
| download | compiler-9567fcbd4d41f603fab53864008add884bd315de.tar.gz compiler-9567fcbd4d41f603fab53864008add884bd315de.zip | |
await transaction
| -rw-r--r-- | worker.js | 4 |
1 files changed, 2 insertions, 2 deletions
@@ -192,8 +192,8 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI || "amqp://localhost", // load records into db try { console.log("inserting batch into db"); - await seq.transaction({ autocommit: false }, (transaction) => { - return Promise.all([ + await seq.transaction({ autocommit: false }, async (transaction) => { + await Promise.all([ model.ParticipantExt.bulkCreate(participant_ext_records, { updateOnDuplicate: [], // all transaction: transaction |