Function sync

packages/queue/src/tasks/sync.ts:6–20

(payload: any, helpers: JobHelpers)

import { Logger } from '../helpers/logger';

export const sync = async (payload: any, helpers: JobHelpers) => {
  const logger = new Logger(helpers.logger);
  logger.info(payload);

  const keepAlive = new KeepAlive(helpers);
  keepAlive.start();

  const fullSync = helpers.job.attempts === 1;

  try {
    await syncJob({ ...payload, fullSync, logger });
  } finally {
    keepAlive.end();
  }
};