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 {