github-featured/triggerdotdev--trigger.dev
2
0
Fork 0
Code Issues Pull Requests Deployments Models Agent Notes Packages Projects Releases Wiki Activity

fixed some key producer tests

Browse Source
This commit is contained in:
Eric Allam
2025-03-11 15:01:59 +00:00
parent 880538ff92
commit 555d9912ec
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal-packages/run-engine/src/run-queue/keyProducer.test.ts
+4 -4
View File
@@ -176,7 +176,7 @@ describe("KeyProducer", () => {
"task/task-name"
);
const key = keyProducer.taskIdentifierCurrentConcurrencyKeyPrefixFromQueue(queueKey);
expect(key).toBe("{org:o1234}:proj:p1234:task:");
expect(key).toBe("{org:o1234}:proj:p1234:env:e1234:task:");
});
it("taskIdentifierCurrentConcurrencyKeyFromQueue", () => {
@@ -192,7 +192,7 @@ describe("KeyProducer", () => {
"task/task-name"
);
const key = keyProducer.taskIdentifierCurrentConcurrencyKeyFromQueue(queueKey, "task-name");
expect(key).toBe("{org:o1234}:proj:p1234:task:task-name");
expect(key).toBe("{org:o1234}:proj:p1234:env:e1234:task:task-name");
});
it("taskIdentifierCurrentConcurrencyKey", () => {
@@ -207,7 +207,7 @@ describe("KeyProducer", () => {
},
"task-name"
);
expect(key).toBe("{org:o1234}:proj:p1234:task:task-name");
expect(key).toBe("{org:o1234}:proj:p1234:env:e1234:task:task-name");
});
it("projectCurrentConcurrencyKey", () => {
@@ -259,7 +259,7 @@ describe("KeyProducer", () => {
"task/task-name"
);
const key = keyProducer.envConcurrencyLimitKeyFromQueue(queueKey);
expect(key).toBe("{org:o1234}:env:e1234:concurrency");
expect(key).toBe("{org:o1234}:proj:p1234:env:e1234:concurrency");
});
it("envCurrentConcurrencyKeyFromQueue", () => {