Skip to content

Commit 5f07ff2

Browse files
committed
fix type issues caused by ts-reset
1 parent 23f3400 commit 5f07ff2

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

internal-packages/redis-worker/src/queue.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -128,7 +128,7 @@ export class SimpleQueue<TMessageCatalog extends MessageCatalogSchema> {
128128
const dequeuedItems = [];
129129

130130
for (const [id, serializedItem] of results) {
131-
const parsedItem = JSON.parse(serializedItem);
131+
const parsedItem = JSON.parse(serializedItem) as any;
132132
if (typeof parsedItem.job !== "string") {
133133
this.logger.error(`Invalid item in queue`, { queue: this.name, id, item: parsedItem });
134134
continue;

internal-packages/redis-worker/src/worker.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -297,7 +297,7 @@ class Worker<TCatalog extends WorkerCatalog> {
297297

298298
private async handleRedriveMessage(channel: string, message: string) {
299299
try {
300-
const { id } = JSON.parse(message);
300+
const { id } = JSON.parse(message) as any;
301301
if (typeof id !== "string") {
302302
throw new Error("Invalid message format: id must be a string");
303303
}

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -653,7 +653,7 @@ export class RunQueue {
653653

654654
private async handleRedriveMessage(channel: string, message: string) {
655655
try {
656-
const { runId, orgId } = JSON.parse(message);
656+
const { runId, orgId } = JSON.parse(message) as any;
657657
if (typeof orgId !== "string" || typeof runId !== "string") {
658658
this.logger.error(
659659
"handleRedriveMessage: invalid message format: runId and orgId must be strings",

0 commit comments

Comments
 (0)