Function getServiceCrons

packages/python/src/crons.ts:58–120

(opts: {
  service?: {
    type?: ServiceType;
    trigger?: JobTrigger;
    name?: string;
    schedule?: string | string[];
  };
  entrypoint?: string;
  rawEntrypoint?: string;
  handlerFunction?: string;
  pythonBin: string;
  env: NodeJS.ProcessEnv;
  workPath: string;
})

 * For "<dynamic>" schedules, calls a Python function via subprocess.
 */
export async function getServiceCrons(opts: {
  service?: {
    type?: ServiceType;
    trigger?: JobTrigger;
    name?: string;
    schedule?: string | string[];
  };
  entrypoint?: string;
  rawEntrypoint?: string;
  handlerFunction?: string;
  pythonBin: string;
  env: NodeJS.ProcessEnv;
  workPath: string;
}): Promise<ServiceCronEntry[] | undefined> {
  const { service, entrypoint, rawEntrypoint, handlerFunction } = opts;
  const isScheduledService = !!service && isScheduleTriggeredService(service);

  if (
    !isScheduledService ||
    !service.name ||
    (typeof service.schedule !== 'string' && !Array.isArray(service.schedule))
  ) {
    return undefined;
  }

  const cronEntrypoint = entrypoint || rawEntrypoint;
  if (!cronEntrypoint) {
    throw new NowBuildError({
      code: 'PYTHON_CRON_NO_ENTRYPOINT',
      message: 'Cron service is missing an entrypoint.',
    });
  }

  if (service.schedule === DYNAMIC_SCHEDULE) {
    return getServiceCronsDynamic({
      serviceName: service.name,
      cronEntrypoint,
      handlerFunction,
      pythonBin: opts.pythonBin,
      env: opts.env,
      workPath: opts.workPath,
    });
  }

  // Static schedule path
  const cronPath = getInternalServiceCronPath(
    service.name,
    cronEntrypoint,
    handlerFunction || 'cron'
  );
  const moduleName = entrypointToModule(cronEntrypoint);
  const resolvedHandler = handlerFunction
    ? `${moduleName}:${handlerFunction}`
    : moduleName;
  const schedules = Array.isArray(service.schedule)
    ? service.schedule
    : [service.schedule];
  return schedules.map(schedule => ({