diff --git a/src/constants.ts b/src/constants.ts index 904ec74..6bcc433 100644 --- a/src/constants.ts +++ b/src/constants.ts @@ -16,7 +16,7 @@ export const NO_CONCURRENCY = 1; export const NOT_SET = "not-set"; export const DEFAULT_RETRIES = 3; -export const VERSION = "v0.2.7"; +export const VERSION = "v0.2.13"; export const SDK_TELEMETRY = `@upstash/workflow@${VERSION}`; export const TELEMETRY_HEADER_SDK = "Upstash-Telemetry-Sdk" as const; diff --git a/src/serve/serve-many.test.ts b/src/serve/serve-many.test.ts index a2a234d..6bae7df 100644 --- a/src/serve/serve-many.test.ts +++ b/src/serve/serve-many.test.ts @@ -17,7 +17,7 @@ describe("serveMany", () => { test("should throw if workflowId contains '/'", () => { const throws = () => serveMany({ - "workflow/one": createWorkflow(async () => {}), + "workflow/one": createWorkflow(async () => { }), }); expect(throws).toThrow( "Invalid workflow name found: 'workflow/one'. Workflow name cannot contain '/'." @@ -26,7 +26,7 @@ describe("serveMany", () => { test("should throw if workflowId doesn't match", async () => { const { POST: handler } = serveMany({ - "workflow-one": createWorkflow(async () => {}), + "workflow-one": createWorkflow(async () => { }), }); const request = new Request("http://localhost:3001/workflow-two", { method: "POST" }); @@ -160,7 +160,7 @@ describe("serveMany", () => { "Upstash-Forward-Upstash-Workflow-Sdk-Version": ["1"], "Upstash-Telemetry-Framework": ["nextjs"], "Upstash-Telemetry-Runtime": ["node@v22.6.0"], - "Upstash-Telemetry-Sdk": ["@upstash/workflow@v0.2.7"], + "Upstash-Telemetry-Sdk": ["@upstash/workflow@v0.2.13"], "Upstash-Workflow-Init": ["false"], "Upstash-Workflow-RunId": ["wfr_id"], "Upstash-Workflow-Runid": ["wfr_id"], @@ -215,7 +215,7 @@ describe("serveMany", () => { "Upstash-Forward-Upstash-Workflow-Sdk-Version": ["1"], "Upstash-Telemetry-Framework": ["nextjs"], "Upstash-Telemetry-Runtime": ["node@v22.6.0"], - "Upstash-Telemetry-Sdk": ["@upstash/workflow@v0.2.7"], + "Upstash-Telemetry-Sdk": ["@upstash/workflow@v0.2.13"], "Upstash-Workflow-Init": ["false"], "Upstash-Workflow-RunId": ["wfr_id"], "Upstash-Workflow-Runid": ["wfr_id"], @@ -289,7 +289,7 @@ describe("serveMany", () => { "upstash-retries": "0", "upstash-telemetry-framework": "nextjs", "upstash-telemetry-runtime": "node@v22.6.0", - "upstash-telemetry-sdk": "@upstash/workflow@v0.2.7", + "upstash-telemetry-sdk": "@upstash/workflow@v0.2.13", "upstash-workflow-calltype": "toCallback", "upstash-workflow-init": "false", "upstash-workflow-runid": "wfr_id", diff --git a/src/serve/serve.test.ts b/src/serve/serve.test.ts index ed7c446..4b55acc 100644 --- a/src/serve/serve.test.ts +++ b/src/serve/serve.test.ts @@ -133,9 +133,9 @@ describe("serve", () => { execute: async (initialPayload, steps, first) => { const request = first ? new Request(WORKFLOW_ENDPOINT, { - body: JSON.stringify(initialPayload), - method: "POST", - }) + body: JSON.stringify(initialPayload), + method: "POST", + }) : getRequest(WORKFLOW_ENDPOINT, workflowRunId, initialPayload, steps); request.headers.set(WORKFLOW_INVOKE_COUNT_HEADER, "2"); @@ -409,7 +409,7 @@ describe("serve", () => { "upstash-workflow-url": WORKFLOW_ENDPOINT, "upstash-telemetry-framework": "unknown", "upstash-telemetry-runtime": "unknown", - "upstash-telemetry-sdk": "@upstash/workflow@v0.2.7", + "upstash-telemetry-sdk": "@upstash/workflow@v0.2.13", }, body: '{"stepId":3,"stepName":"step 3","stepType":"Run","out":"\\"combined results: result 1,result 2\\"","concurrent":1}', }, @@ -458,7 +458,7 @@ describe("serve", () => { "upstash-workflow-url": WORKFLOW_ENDPOINT, "upstash-telemetry-framework": "unknown", "upstash-telemetry-runtime": "unknown", - "upstash-telemetry-sdk": "@upstash/workflow@v0.2.7", + "upstash-telemetry-sdk": "@upstash/workflow@v0.2.13", }, body: '{"stepId":1,"stepName":"sleep-step","stepType":"SleepFor","sleepFor":1,"concurrent":1}', }, @@ -511,7 +511,7 @@ describe("serve", () => { "upstash-failure-callback-workflow-url": "https://requestcatcher.com/api", "upstash-telemetry-framework": "unknown", "upstash-telemetry-runtime": "unknown", - "upstash-telemetry-sdk": "@upstash/workflow@v0.2.7", + "upstash-telemetry-sdk": "@upstash/workflow@v0.2.13", }, body: '{"stepId":1,"stepName":"sleep-step","stepType":"SleepFor","sleepFor":1,"concurrent":1}', }, @@ -566,7 +566,7 @@ describe("serve", () => { "upstash-failure-callback-workflow-url": "https://requestcatcher.com/api", "upstash-telemetry-framework": "unknown", "upstash-telemetry-runtime": "unknown", - "upstash-telemetry-sdk": "@upstash/workflow@v0.2.7", + "upstash-telemetry-sdk": "@upstash/workflow@v0.2.13", }, body: '{"stepId":1,"stepName":"sleep-step","stepType":"SleepFor","sleepFor":1,"concurrent":1}', }, @@ -661,7 +661,7 @@ describe("serve", () => { "upstash-retries": "4", "upstash-telemetry-framework": "unknown", "upstash-telemetry-runtime": "unknown", - "upstash-telemetry-sdk": "@upstash/workflow@v0.2.7", + "upstash-telemetry-sdk": "@upstash/workflow@v0.2.13", "upstash-timeout": "10", "upstash-workflow-calltype": "toCallback", "upstash-workflow-init": "false", @@ -875,7 +875,7 @@ describe("serve", () => { "Upstash-Workflow-Url": [WORKFLOW_ENDPOINT], "Upstash-Telemetry-Framework": ["unknown"], "Upstash-Telemetry-Runtime": ["unknown"], - "Upstash-Telemetry-Sdk": ["@upstash/workflow@v0.2.7"], + "Upstash-Telemetry-Sdk": ["@upstash/workflow@v0.2.13"], }, timeoutUrl: WORKFLOW_ENDPOINT, url: WORKFLOW_ENDPOINT, @@ -1158,7 +1158,7 @@ describe("serve", () => { "upstash-forward-test-header": headerValue, "upstash-telemetry-framework": "unknown", "upstash-telemetry-runtime": "unknown", - "upstash-telemetry-sdk": "@upstash/workflow@v0.2.7", + "upstash-telemetry-sdk": "@upstash/workflow@v0.2.13", }, body: '{"stepId":1,"stepName":"sleep-step","stepType":"SleepFor","sleepFor":1,"concurrent":1}', },