From 14436d8d4cb5839155b6294854cd176b489cec9e Mon Sep 17 00:00:00 2001 From: nicktrn <55853254+nicktrn@users.noreply.github.com> Date: Mon, 14 Apr 2025 12:19:22 +0100 Subject: [PATCH] be explicit about only returning managed deployments --- internal-packages/run-engine/src/engine/db/worker.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal-packages/run-engine/src/engine/db/worker.ts b/internal-packages/run-engine/src/engine/db/worker.ts index 701987581..8bc2817d6 100644 --- a/internal-packages/run-engine/src/engine/db/worker.ts +++ b/internal-packages/run-engine/src/engine/db/worker.ts @@ -100,7 +100,7 @@ export async function getRunWithBackgroundWorkerTasks( } else { workerWithTasks = workerId ? await getWorkerDeploymentFromWorker(prisma, workerId) - : await getWorkerFromCurrentlyPromotedDeployment(prisma, run.runtimeEnvironmentId); + : await getManagedWorkerFromCurrentlyPromotedDeployment(prisma, run.runtimeEnvironmentId); } if (!workerWithTasks) { @@ -260,7 +260,7 @@ export async function getWorkerById( return { worker, tasks: worker.tasks, queues: worker.queues, deployment: worker.deployment }; } -export async function getWorkerFromCurrentlyPromotedDeployment( +export async function getManagedWorkerFromCurrentlyPromotedDeployment( prisma: PrismaClientOrTransaction, environmentId: string ): Promise {