Method create

backend/src/schedules/schedules.service.ts:41–118

(auth: AuthContext | null, dto: CreateScheduleRequestDto)

  }

  async create(auth: AuthContext | null, dto: CreateScheduleRequestDto): Promise<WorkflowSchedule> {
    await this.workflowsService.ensureWorkflowAdminAccess(dto.workflowId, auth);
    const context = await this.workflowsService.getCompiledWorkflowContext(
      dto.workflowId,
      { versionId: dto.workflowVersionId },
      auth,
    );

    const normalizedPayload: ScheduleInputPayload = dto.inputPayload ?? {
      runtimeInputs: {},
      nodeOverrides: {},
    };

    this.validateSchedulePayload(context.definition, normalizedPayload);

    const record = await this.repository.create({
      workflowId: context.workflow.id,
      workflowVersionId: context.version.id,
      workflowVersion: context.version.version,
      name: dto.name,
      description: dto.description ?? null,
      cronExpression: dto.cronExpression,
      timezone: dto.timezone,
      humanLabel: dto.humanLabel ?? null,
      overlapPolicy: dto.overlapPolicy ?? 'skip',
      catchupWindowSeconds: dto.catchupWindowSeconds ?? 0,
      status: 'active',
      inputPayload: normalizedPayload,
      organizationId: context.organizationId,
    });

    const dispatchArgs = this.buildDispatchArgs({
      workflowId: record.workflowId,
      workflowVersionId: record.workflowVersionId,
      workflowVersion: record.workflowVersion,
      organizationId: record.organizationId ?? null,
      scheduleId: record.id,
      scheduleName: record.name,
      payload: normalizedPayload,
    });

    try {
      await this.temporalService.createSchedule({
        scheduleId: record.id,
        organizationId: context.organizationId,
        cronExpression: record.cronExpression,
        timezone: record.timezone,
        overlapPolicy: (record.overlapPolicy as ScheduleOverlapPolicy) ?? 'skip',
        catchupWindowSeconds: record.catchupWindowSeconds ?? 0,
        memo: {
          workflowId: record.workflowId,
          workflowVersionId: record.workflowVersionId,
          workflowVersion: record.workflowVersion,
          inputPayload: record.inputPayload,
        },
        dispatchArgs,
      });
    } catch (error) {