Skip to content

Commit 33ff1db

Browse files
committed
start.claimURIs: initialize ChangeRecord.Version to 1
Mirrors the request-store pattern (Request.Version starts at 1).
1 parent 693fb79 commit 33ff1db

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

orchestrator/controller/start/start.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -162,6 +162,7 @@ func (c *Controller) claimURIs(ctx context.Context, request entity.Request) erro
162162
Queue: request.Queue,
163163
CreatedAt: now,
164164
UpdatedAt: now,
165+
Version: 1,
165166
}
166167
if err := c.changeStore.Create(ctx, record); err != nil {
167168
return fmt.Errorf("failed to claim uri=%s for request %s: %w", uri, request.ID, err)

0 commit comments

Comments
 (0)