Skip to content

Commit a27e86f

Browse files
committed
Queue with 0 attempts
Signed-off-by: paulhenri-l <25308170+paulhenri-l@users.noreply.github.com>
1 parent 29d029d commit a27e86f

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

packages/world-postgres/src/queue.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ export function createQueue(
3535
const payload = {
3636
id: queueId,
3737
data: body,
38-
attempt: 1,
38+
attempt: 0,
3939
messageId,
4040
idempotencyKey: opts?.idempotencyKey,
4141
queueName: `${prefix}${queueId}`,

packages/world-postgres/src/storage.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -596,7 +596,7 @@ export function createStepsStorage(drizzle: Drizzle): Storage['steps'] {
596596
stepName: data.stepName,
597597
input: inputBuffer,
598598
status: 'pending',
599-
attempt: 1,
599+
attempt: 0,
600600
})
601601
.onConflictDoNothing()
602602
.returning();

0 commit comments

Comments
 (0)