Method _onCronFire

packages/server/src/schedule/ScheduleBeat.ts:224–246

* Callback fired by node-cron. Delegates to the shared ScheduleExecutor * with Beat-specific cleanup callbacks.

(scheduleRecordId: string)

     * with Beat-specific cleanup callbacks.
     */
    private async _onCronFire(scheduleRecordId: string): Promise<void> {
        const appServer = getRunningExpressApp()
        const ctx = {
            appDataSource: appServer.AppDataSource,
            componentNodes: appServer.nodesPool.componentNodes,
            telemetry: appServer.telemetry,
            cachePool: appServer.cachePool,
            usageCacheManager: appServer.usageCacheManager,
            sseStreamer: appServer.sseStreamer,
            identityManager: appServer.identityManager
        }

        await executeScheduleJob(ctx, scheduleRecordId, {
            onRecordNotFoundOrDisabled: () => {
                this._removeCronJob(scheduleRecordId)
            },
            onRecordExpiredOrInvalid: async (record) => {
                record.enabled = false
                await appServer.AppDataSource.getRepository(ScheduleRecord).save(record)
                this._removeCronJob(record.id)
            }
        })
    }
}