Function enqueue

app/src/server/tasks/defineTask.ts:27–34

(payload: TPayload, spec?: TaskSpec)

  specDefaults?: TaskSpec;
}) {
  const enqueue = async (payload: TPayload, spec?: TaskSpec) => {
    const mergedSpec = merge({}, options.specDefaults, spec);

    await options.beforeEnqueue?.(payload);

    const utils = await workerUtils();
    return await utils.addJob(options.id, payload, mergedSpec);
  };

  const handler = (payload: TPayload, helpers: Helpers) => {
    helpers.logger.debug(`Running task ${options.id} with payload: ${JSON.stringify(payload)}`);