diff --git a/app/server/src/queue/AdapterQueue.ts b/app/server/src/queue/AdapterQueue.ts index fd40ece..6cccd67 100644 --- a/app/server/src/queue/AdapterQueue.ts +++ b/app/server/src/queue/AdapterQueue.ts @@ -300,6 +300,8 @@ export class AdapterQueue implements CacheScheduler { await this.queue(`x:timeline:${a.handle}`); } } + } else if (s.source_kind === 'finra-bulk') { + await this.queue('finra-bulk:finraShortinterest:latest'); } const nextEnqueue = new Date(Date.now() + s.interval_ms).toISOString(); this._db.prepare("UPDATE queue_schedules SET last_enqueued=?, next_enqueue=? WHERE source_kind=?").run(now, nextEnqueue, s.source_kind); @@ -315,6 +317,7 @@ export class AdapterQueue implements CacheScheduler { ['sec-lint-holders', 7 * 86400000], ['sec-lint-insiders', 7 * 86400000], ['x', 3600000], + ['finra-bulk', 14 * 86400000], ]; const insert = this._db.prepare("INSERT OR IGNORE INTO queue_schedules (source_kind, interval_ms, last_enqueued, next_enqueue) VALUES (?,?,?,?)"); for (const [kind, ms] of defaults) {