( params: TaskOptions<TPayloadIn, TPayloadOut, TOutput, TContext, TIndentifier> )
| 225 | } |
| 226 | |
| 227 | export function createTask< |
| 228 | TPayloadIn, |
| 229 | TPayloadOut, |
| 230 | TOutput, |
| 231 | TContext extends object, |
| 232 | TIndentifier extends string, |
| 233 | >( |
| 234 | params: TaskOptions<TPayloadIn, TPayloadOut, TOutput, TContext, TIndentifier> |
| 235 | ): Task<TPayloadIn, TPayloadOut, TOutput, TIndentifier> { |
| 236 | const task: Task<TPayloadIn, TPayloadOut, TOutput, TIndentifier> = { |
| 237 | id: params.id, |
| 238 | trigger: async (payload, options) => { |
| 239 | return { |
| 240 | id: "run_1234", |
| 241 | }; |
| 242 | }, |
| 243 | triggerAndWait: async (payload, options) => { |
| 244 | const output = await params.run({ |
| 245 | meta: { run: "run_1234" }, |
| 246 | payload: payload as unknown as inferTaskPayloadOut<TPayloadIn, TPayloadOut>, |
| 247 | ctx: {} as TContext, |
| 248 | }); |
| 249 | |
| 250 | return { |
| 251 | ok: true, |
| 252 | id: "run_1234", |
| 253 | output, |
| 254 | }; |
| 255 | }, |
| 256 | }; |
| 257 | |
| 258 | return task; |
| 259 | } |
| 260 | |
| 261 | export type ZodTaskOptions< |
| 262 | TOutput, |
no test coverage detected
searching dependent graphs…