Function createTask

packages/trigger-sdk/src/v3/shared.ts:332–696

(
  params: TaskOptions<TInput, TOutput, TInitOutput>
)

};

export function createTask<TInput = void, TOutput = unknown, TInitOutput extends InitOutput = any>(
  params: TaskOptions<TInput, TOutput, TInitOutput>
): Task<TInput, TOutput> {
  const task: Task<TInput, TOutput> = {
    id: params.id,
    trigger: async (payload, options) => {
      const apiClient = apiClientManager.client;

      if (!apiClient) {
        throw apiClientMissingError();
      }

      const taskMetadata = taskCatalog.getTaskMetadata(params.id);

      const payloadPacket = await stringifyIO(payload);

      const handle = await tracer.startActiveSpan(
        taskMetadata ? "Trigger" : `${params.id} trigger()`,
        async (span) => {
          const response = await apiClient.triggerTask(
            params.id,
            {
              payload: payloadPacket.data,
              options: {
                queue: options?.queue ?? params.queue,
                concurrencyKey: options?.concurrencyKey,
                test: taskContext.ctx?.run.isTest,
                payloadType: payloadPacket.dataType,
                idempotencyKey: options?.idempotencyKey,
              },
            },
            { spanParentAsLink: true }
          );

          span.setAttribute("messaging.message.id", response.id);

          return response;
        },
        {
          kind: SpanKind.PRODUCER,
          attributes: {
            [SEMATTRS_MESSAGING_OPERATION]: "publish",
            [SemanticInternalAttributes.STYLE_ICON]: "trigger",
            ["messaging.client_id"]: taskContext.worker?.id,
            [SEMATTRS_MESSAGING_DESTINATION]: params.queue?.name ?? params.id,
            [SEMATTRS_MESSAGING_SYSTEM]: "trigger.dev",
            ...(taskMetadata
              ? accessoryAttributes({
                  items: [
                    {
                      text: `${taskMetadata.exportName}.trigger()`,
                      variant: "normal",
                    },
                  ],
                  style: "codepath",
                })
              : {}),
          },