More MarQS upgrades

- Extract the queue priortity choosing strategy into an interface
- Implement a much better weighted average strategy
- “Slide the window” of queue candidates if the parent queue sends all at-capacity queues (so we won’t get stuck attempting to choose the same 12 full queues)
- Added some unit tests for the priority stuff
- Added some ideas for expanding the priority choosing strategy with more dynamic features

Author: ericallam

apps/webapp/app/routes/admin.api.v1.environments.$environmentId.ts

@@ -2,7 +2,7 @@ import { ActionFunctionArgs, json } from "@remix-run/server-runtime";
 import { z } from "zod";
 import { prisma } from "~/db.server";
 import { authenticateApiRequestWithPersonalAccessToken } from "~/services/personalAccessToken.server";
-import { marqs } from "~/v3/marqs.server";
+import { marqs } from "~/v3/marqs/index.server";
 
 const ParamsSchema = z.object({
   environmentId: z.string(),
@@ -60,7 +60,7 @@ export async function action({ request, params }: ActionFunctionArgs) {
     },
   });
 
-  await marqs?.updateGlobalConcurrencyLimits(environment);
+  await marqs?.updateEnvConcurrencyLimits(environment);
 
   return json({ success: true });
 }

apps/webapp/app/v3/marqs/devQueueConsumer.server.ts

@@ -13,7 +13,7 @@ import { AuthenticatedEnvironment } from "~/services/apiAuth.server";
 import { logger } from "~/services/logger.server";
 import { EnvironmentVariablesRepository } from "../environmentVariables/environmentVariablesRepository.server";
 import { generateFriendlyId } from "../friendlyIdentifiers";
-import { marqs } from "../marqs.server";
+import { marqs } from "~/v3/marqs/index.server";
 import { CancelAttemptService } from "../services/cancelAttempt.server";
 import { CompleteAttemptService } from "../services/completeAttempt.server";
 import { attributesFromAuthenticatedEnv } from "../tracer.server";