Skip to content

Commit 67b9f84

Browse files
committed
add missing idempotency keys to wait for dep replays
1 parent 045d0c0 commit 67b9f84

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

packages/cli-v3/src/workers/prod/entry-point.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1235,7 +1235,7 @@ class ProdWorker {
12351235
try {
12361236
await backoff.wait(attempt + 1);
12371237

1238-
await this.#waitForTaskHandlerFactory("replay")(message);
1238+
await this.#waitForTaskHandlerFactory("replay")(message, idempotencyKey);
12391239
} catch (error) {
12401240
if (error instanceof ExponentialBackoff.RetryLimitExceeded) {
12411241
logger.error("wait for task replay retry limit exceeded", { error });
@@ -1278,7 +1278,7 @@ class ProdWorker {
12781278
try {
12791279
await backoff.wait(attempt + 1);
12801280

1281-
await this.#waitForBatchHandlerFactory("replay")(message);
1281+
await this.#waitForBatchHandlerFactory("replay")(message, idempotencyKey);
12821282
} catch (error) {
12831283
if (error instanceof ExponentialBackoff.RetryLimitExceeded) {
12841284
logger.error("wait for batch replay retry limit exceeded", { error });

0 commit comments

Comments
 (0)