github-featured/triggerdotdev--trigger.dev
2
0
Fork 0
Code Issues Pull Requests Deployments Models Agent Notes Packages Projects Releases Wiki Activity

Recover when orphaned run messages are received

Browse Source
This commit is contained in:
Eric Allam
2023-01-04 16:05:10 +00:00
parent 17683d2377
commit c492531ce0
1 changed files with 21 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/trigger-sdk/src/client.ts
+21 -6
View File
@@ -116,9 +116,14 @@ export class TriggerClient<TSchema extends z.ZodTypeAny> {
);
if (!waitCallbacks) {
throw new Error(
`Could not find wait callbacks for wait ID ${data.meta.runId}:${data.key}`
this.#logger.debug(
`Could not find wait callbacks for wait ID ${messageKey(
data.meta.runId,
data.key
)}. This can happen when a workflow run is resumed`
);
return true;
}
const { resolve } = waitCallbacks;
@@ -135,9 +140,14 @@ export class TriggerClient<TSchema extends z.ZodTypeAny> {
);
if (!requestCallbacks) {
throw new Error(
`Could not find request callbacks for request ID ${data.meta.runId}:${data.key}`
this.#logger.debug(
`Could not find request callbacks for request ID ${messageKey(
data.meta.runId,
data.key
)}. This can happen when a workflow run is resumed`
);
return true;
}
const { resolve } = requestCallbacks;
@@ -154,9 +164,14 @@ export class TriggerClient<TSchema extends z.ZodTypeAny> {
);
if (!requestCallbacks) {
throw new Error(
`Could not find request callbacks for request id ${data.meta.runId}:${data.key}`
this.#logger.debug(
`Could not find request callbacks for request ID ${messageKey(
data.meta.runId,
data.key
)}. This can happen when a workflow run is resumed`
);
return true;
}
const { reject } = requestCallbacks;