Function createTask

experiments/with-generic-parser.ts:209–240

(
  params: TaskOptions<TOutput, TContext, TIndentifier, TParser>
)

}

export function createTask<
  TOutput,
  TContext extends object,
  TIndentifier extends string,
  TParser extends Parser | undefined = undefined,
>(
  params: TaskOptions<TOutput, TContext, TIndentifier, TParser>
): Task<TOutput, TIndentifier, TParser> {
  const task: Task<TOutput, TIndentifier, TParser> = {
    id: params.id,
    trigger: async (payload, options) => {
      return {
        id: "run_1234",
      };
    },
    triggerAndWait: async (payload, options) => {
      const output = await params.run({
        meta: { run: "run_1234" },
        payload: payload as unknown as inferParserOut<TParser>, // Actually do the parsing
        ctx: {} as TContext,
      });

      return {
        ok: true,
        id: "run_1234",
        output,
      };
    },
  };

  return task;
}

export interface TaskLibraryRecord {
  [key: string]: AnyTask | TaskLibraryRecord;