re2: WIP env based queue selection algo

Author: ericallam

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

@@ -1,4 +1,3 @@
-import { flattenAttributes } from "@trigger.dev/core/v3";
 import { createCache, DefaultStatefulContext, Namespace, Cache as UnkeyCache } from "@unkey/cache";
 import { MemoryStore } from "@unkey/cache/stores";
 import { randomUUID } from "crypto";

internal-packages/redis/package.json

@@ -15,4 +15,4 @@
   "scripts": {
     "typecheck": "tsc --noEmit"
   }
-}
+}

internal-packages/redis/src/index.ts

@@ -1,6 +1,8 @@
 import { Redis, RedisOptions } from "ioredis";
 import { Logger } from "@trigger.dev/core/logger";
 
+export { Redis, type Callback, type RedisOptions, type Result } from "ioredis";
+
 const defaultOptions: Partial<RedisOptions> = {
   retryStrategy: (times: number) => {
     const delay = Math.min(times * 50, 1000);

internal-packages/redis/tsconfig.json

@@ -2,8 +2,8 @@
   "compilerOptions": {
     "target": "ES2019",
     "lib": ["ES2019", "DOM", "DOM.Iterable", "DOM.AsyncIterable"],
-    "module": "CommonJS",
-    "moduleResolution": "Node",
+    "module": "Node16",
+    "moduleResolution": "Node16",
     "moduleDetection": "force",
     "verbatimModuleSyntax": false,
     "types": ["vitest/globals"],

internal-packages/run-engine/package.json

@@ -4,25 +4,28 @@
   "version": "0.0.1",
   "main": "./src/index.ts",
   "types": "./src/index.ts",
+  "type": "module",
   "dependencies": {
     "@internal/redis": "workspace:*",
     "@internal/redis-worker": "workspace:*",
-    "@opentelemetry/api": "^1.9.0",
-    "@opentelemetry/semantic-conventions": "^1.27.0",
+    "@internal/tracing": "workspace:*",
     "@trigger.dev/core": "workspace:*",
     "@trigger.dev/database": "workspace:*",
     "assert-never": "^1.2.1",
     "ioredis": "^5.3.2",
     "nanoid": "^3.3.4",
     "redlock": "5.0.0-beta.2",
-    "zod": "3.23.8"
+    "zod": "3.23.8",
+    "@unkey/cache": "^1.5.0",
+    "seedrandom": "^3.0.5"
   },
   "devDependencies": {
     "@internal/testcontainers": "workspace:*",
-    "vitest": "^1.4.0"
+    "vitest": "^1.4.0",
+    "@types/seedrandom": "^3.0.8"
   },
   "scripts": {
     "typecheck": "tsc --noEmit",
     "test": "vitest --sequence.concurrent=false"
   }
-}
+}