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

Fixed task runs with unsanitized queue names

Browse Source
This commit is contained in:
Eric Allam
2024-04-30 21:17:23 +01:00
parent e24631e2dd
commit f124d94efc
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/webapp/app/v3/services/triggerTask.server.ts
+2 -2
View File
@@ -10,7 +10,7 @@ import { $transaction } from "~/db.server";
import { AuthenticatedEnvironment } from "~/services/apiAuth.server";
import { eventRepository } from "../eventRepository.server";
import { generateFriendlyId } from "../friendlyIdentifiers";
import { marqs } from "~/v3/marqs/index.server";
import { marqs, sanitizeQueueName } from "~/v3/marqs/index.server";
import { uploadToObjectStore } from "../r2.server";
import { BaseService } from "./baseService.server";
@@ -109,7 +109,7 @@ export class TriggerTaskService extends BaseService {
select: { lastNumber: true },
});
const queueName = body.options?.queue?.name ?? `task/${taskId}`;
const queueName = sanitizeQueueName(body.options?.queue?.name ?? `task/${taskId}`);
event.setAttribute("queueName", queueName);
span.setAttribute("queueName", queueName);