Skip to content

Commit 14436d8

Browse files
committed
be explicit about only returning managed deployments
1 parent 3238514 commit 14436d8

File tree

1 file changed

+2
-2
lines changed
  • internal-packages/run-engine/src/engine/db

1 file changed

+2
-2
lines changed

internal-packages/run-engine/src/engine/db/worker.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -100,7 +100,7 @@ export async function getRunWithBackgroundWorkerTasks(
100100
} else {
101101
workerWithTasks = workerId
102102
? await getWorkerDeploymentFromWorker(prisma, workerId)
103-
: await getWorkerFromCurrentlyPromotedDeployment(prisma, run.runtimeEnvironmentId);
103+
: await getManagedWorkerFromCurrentlyPromotedDeployment(prisma, run.runtimeEnvironmentId);
104104
}
105105

106106
if (!workerWithTasks) {
@@ -260,7 +260,7 @@ export async function getWorkerById(
260260
return { worker, tasks: worker.tasks, queues: worker.queues, deployment: worker.deployment };
261261
}
262262

263-
export async function getWorkerFromCurrentlyPromotedDeployment(
263+
export async function getManagedWorkerFromCurrentlyPromotedDeployment(
264264
prisma: PrismaClientOrTransaction,
265265
environmentId: string
266266
): Promise<WorkerDeploymentWithWorkerTasks | null> {

0 commit comments

Comments
 (0)