diff --git a/pkg/repository/sequence/mongo.go b/pkg/repository/sequence/mongo.go index daac5baac05..607255a737e 100644 --- a/pkg/repository/sequence/mongo.go +++ b/pkg/repository/sequence/mongo.go @@ -94,7 +94,6 @@ func (r *MongoRepository) GetNextExecutionNumber(ctx context.Context, name strin } opts := options.FindOneAndUpdate() - opts.SetUpsert(false) opts.SetReturnDocument(options.After) err = r.Coll.FindOneAndUpdate(ctx, bson.M{"_id": id}, bson.M{"$inc": bson.M{"number": 1}}, opts).Decode(&executionNumber)