telemetry: upsert for debugging

1 files changed, 3 insertions, 1 deletions

diff --git a/worker.js b/worker.js
index 45e780f..27af4bc 100644
--- a/worker.js
+++ b/worker.js
@@ -520,7 +520,9 @@ function flatten(obj) {
                 );
                 await Promise.map(chunks(participant_phase_records), async (p_p_r) =>
                     model.ParticipantPhases.bulkCreate(p_p_r, {
-                        ignoreDuplicates: true,
+                        /* ignoreDuplicates: true, TODO DEBUG */
+                        ignoreDuplicates: false,
+                        updateOnDuplicate: [],
                         transaction: transaction
                     }), { concurrency: MAXCONNS }
                 );