Method createSchedule

backend/src/temporal/temporal.service.ts:355–378

(options: CreateTemporalScheduleInput)

  }

  async createSchedule(options: CreateTemporalScheduleInput): Promise<void> {
    const client = await this.getScheduleClient();
    await client.create({
      scheduleId: options.scheduleId,
      memo: options.memo,
      spec: {
        cronExpressions: [options.cronExpression],
        timezone: options.timezone,
      },
      action: {
        type: 'startWorkflow',
        workflowType: 'scheduleTriggerWorkflow',
        taskQueue: this.defaultTaskQueue,
        args: [options.dispatchArgs],
        workflowId: `schedule-${options.scheduleId}`,
      },
      policies: {
        overlap: this.mapOverlapPolicy(options.overlapPolicy),
        catchupWindow: options.catchupWindowSeconds
          ? options.catchupWindowSeconds * 1000
          : undefined,
      },
    });
  }

  async updateSchedule(options: UpdateTemporalScheduleInput): Promise<void> {
    const client = await this.getScheduleClient();