MCPcopy Create free account
hub / github.com/FlowiseAI/Flowise / _upsertJob

Method _upsertJob

packages/server/src/schedule/ScheduleBeat.ts:103–111  ·  view source on GitHub ↗

* Register (or re-register) a schedule job via the active backend.

(record: ScheduleRecord)

Source from the content-addressed store, hash-verified

101 * Register (or re-register) a schedule job via the active backend.
102 */
103 private async _upsertJob(record: ScheduleRecord): Promise<void> {
104 if (this.isQueueMode) {
105 const scheduleQueue = this._getScheduleQueue()
106 if (!scheduleQueue) return
107 await scheduleQueue.upsertJobScheduler(record)
108 } else {
109 this._upsertCronJob(record)
110 }
111 }
112
113 /**
114 * Remove a schedule job from the active backend.

Callers 2

onScheduleChangedMethod · 0.95
_syncAllJobsMethod · 0.95

Calls 3

_getScheduleQueueMethod · 0.95
_upsertCronJobMethod · 0.95
upsertJobSchedulerMethod · 0.80

Tested by

no test coverage detected