We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b1b725a commit 12c4a58Copy full SHA for 12c4a58
packages/world-postgres/src/queue.ts
@@ -35,7 +35,7 @@ export function createQueue(
35
const payload = {
36
id: queueId,
37
data: body,
38
- attempt: 1,
+ attempt: 0,
39
messageId,
40
idempotencyKey: opts?.idempotencyKey,
41
queueName: `${prefix}${queueId}`,
packages/world-postgres/src/storage.ts
@@ -596,7 +596,7 @@ export function createStepsStorage(drizzle: Drizzle): Storage['steps'] {
596
stepName: data.stepName,
597
input: inputBuffer,
598
status: 'pending',
599
600
})
601
.onConflictDoNothing()
602
.returning();
0 commit comments