Function updateScheduleAfterRun

packages/server/src/services/schedule/index.ts:184–197

(
    appDataSource: DataSource,
    scheduleRecordId: string,
    cronExpression: string,
    timezone: string = 'UTC'
)

// ---------------------------------------------------------------------------

const updateScheduleAfterRun = async (
    appDataSource: DataSource,
    scheduleRecordId: string,
    cronExpression: string,
    timezone: string = 'UTC'
): Promise<void> => {
    try {
        const lastRunAt = new Date()
        const nextRunAt = computeNextRunAt(cronExpression, timezone, lastRunAt) ?? undefined
        await appDataSource.getRepository(ScheduleRecord).update({ id: scheduleRecordId }, { lastRunAt, nextRunAt })
    } catch (error) {
        logger.error(`[ScheduleService]: updateScheduleAfterRun failed for ${scheduleRecordId}: ${getErrorMessage(error)}`)
    }
}

/**
 * Returns the current schedule record and whether it can be enabled,