Upsert pins if unable to insert due to conflict

Signed-off-by: Nicko Guyer <[email protected]>
kaleido-io · Nov 12, 2024 · a7fcea7 · a7fcea7
1 parent 552ad1e
commit a7fcea7
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/internal/database/sqlcommon/pin_sql.go b/internal/database/sqlcommon/pin_sql.go
@@ -93,13 +93,13 @@ func (s *SQLCommon) UpsertPin(ctx context.Context, pin *core.Pin) (err error) {
 }
 
 func (s *SQLCommon) attemptPinInsert(ctx context.Context, tx *dbsql.TXWrapper, pin *core.Pin) (err error) {
-	pin.Sequence, err = s.InsertTx(ctx, pinsTable, tx,
+	requestConflictEmptyResult := true
+	pin.Sequence, err = s.InsertTxExt(ctx, pinsTable, tx,
 		s.setPinInsertValues(sq.Insert(pinsTable).Columns(pinColumns...), pin),
 		func() {
 			log.L(ctx).Debugf("Triggering creation event for pin %d", pin.Sequence)
 			s.callbacks.OrderedCollectionNSEvent(database.CollectionPins, core.ChangeEventTypeCreated, pin.Namespace, pin.Sequence)
-		},
-	)
+		}, requestConflictEmptyResult)
 	return err
 }