|
6 | 6 | ensAddresses, |
7 | 7 | providers |
8 | 8 | } from "@polywrap/test-env-js"; |
9 | | -import { createPolywrapClient, PolywrapClient, PolywrapClientConfig } from "../.."; |
| 9 | +import { createPolywrapClient, JobResult, PolywrapClient, PolywrapClientConfig } from "../.."; |
10 | 10 | import { outPropWorkflow, sanityWorkflow } from "./workflow-test-cases"; |
11 | 11 |
|
12 | 12 | jest.setTimeout(200000); |
@@ -89,17 +89,17 @@ describe("workflow", () => { |
89 | 89 | test("sanity workflow", async () => { |
90 | 90 | await client.run({ |
91 | 91 | workflow: sanityWorkflow, |
92 | | - onExecution: async (id: string, data: unknown, error: unknown) => { |
93 | | - await tests[id](data, error); |
| 92 | + onExecution: async (id: string, jobResult: JobResult) => { |
| 93 | + await tests[id](jobResult.data, jobResult.error); |
94 | 94 | }, |
95 | 95 | }); |
96 | 96 | }); |
97 | 97 |
|
98 | 98 | test("workflow with output propagation", async () => { |
99 | 99 | await client.run({ |
100 | 100 | workflow: outPropWorkflow, |
101 | | - onExecution: async (id: string, data: unknown, error: unknown) => { |
102 | | - await tests[id](data, error); |
| 101 | + onExecution: async (id: string, jobResult: JobResult) => { |
| 102 | + await tests[id](jobResult.data, jobResult.error); |
103 | 103 | }, |
104 | 104 | }); |
105 | 105 | }); |
|
0 commit comments