Max/zkldi_Tachi
1
0
Fork 0
mirror of https://github.com/zkldi/Tachi.git synced 2026-09-22 23:18:05 +03:00
Code Issues Packages Projects Releases Wiki Activity

fix: scope (#1689)

Browse Source
This commit is contained in:
zk
2026-06-19 01:13:36 +01:00
committed by GitHub
parent a28fe51121
commit 19a94c8785
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
typescript/server/src/lib/jobs/job-queue/worker-pubsub.ts
+6 -3
View File
@@ -1,13 +1,16 @@
import { log } from "#lib/log/log";
import { TachiConfig } from "#lib/setup/config";
import { RedisClient } from "#services/redis/redis";
export const JOB_QUEUE_EVENTS_CHANNEL = "job-queue:events";
const PREFIX = TachiConfig.NAME;
export const JOB_QUEUE_EVENTS_CHANNEL = `${PREFIX}:job-queue:events`;
/**
* Redis key written by the worker process on startup so the HTTP process
* (and therefore the SSE stream) knows how many worker slots exist.
*/
export const WORKER_COUNT_REDIS_KEY = "job-queue:worker-count";
export const WORKER_COUNT_REDIS_KEY = `${PREFIX}:job-queue:worker-count`;
export type WorkerPubSubEvent =
| {
@@ -39,7 +42,7 @@ export function PublishJobEvent(event: WorkerPubSubEvent): void {
/** Per-import Redis pub/sub channel name. */
export function importProgressChannel(importID: string): string {
return `import-progress:${importID}`;
return `${PREFIX}:import-progress:${importID}`;
}
export type ImportProgressEvent =