Skip to content

Commit a9fe94f

Browse files
committed
fix(run-engine): keep the ck-limits key builders while the Lua reads remain
The per-key admit reads are removed in the PR above alongside the rest of the engine-internal plumbing; the key builders they reference stay until then so every level of the stack compiles.
1 parent 068c738 commit a9fe94f

2 files changed

Lines changed: 11 additions & 0 deletions

File tree

internal-packages/run-engine/src/run-queue/keyProducer.ts

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -366,6 +366,14 @@ export class RunQueueFullKeyProducer implements RunQueueKeyProducer {
366366
return `${this.baseQueueKeyFromQueue(queue)}:${constants.TOTAL_CONCURRENCY_LIMIT_PART}`;
367367
}
368368

369+
queueCkLimitsKey(env: RunQueueKeyProducerEnvironment, queue: string): string {
370+
return `${this.queueKey(env, queue)}:ckLimits`;
371+
}
372+
373+
queueCkLimitsKeyFromQueue(queue: string): string {
374+
return `${this.baseQueueKeyFromQueue(queue)}:ckLimits`;
375+
}
376+
369377
isCkWildcard(queue: string): boolean {
370378
return queue.endsWith(":ck:*");
371379
}

internal-packages/run-engine/src/run-queue/types.ts

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -111,6 +111,9 @@ export interface RunQueueKeyProducer {
111111
queueTotalConcurrencyLimitKey(env: RunQueueKeyProducerEnvironment, queue: string): string;
112112
queueTotalConcurrencyLimitKeyFromQueue(queue: string): string;
113113

114+
queueCkLimitsKey(env: RunQueueKeyProducerEnvironment, queue: string): string;
115+
queueCkLimitsKeyFromQueue(queue: string): string;
116+
114117
//env oncurrency
115118
envCurrentConcurrencyKey(env: EnvDescriptor): string;
116119
envCurrentConcurrencyKey(env: RunQueueKeyProducerEnvironment): string;

0 commit comments

Comments
 (0)