Skip to content

Commit 385f82e

Browse files
committed
chore(core,webapp): remove dead v3 socket message catalogs and MarQS env vars
After confirming no cross-repo consumers (infra/cloud/compute), remove the now-dead v3 socket message catalogs from @trigger.dev/core (coordinator/provider/shared-queue/ prod-worker + the legacy background-worker websocket catalogs) and the unreferenced MarQS / shared-queue-consumer environment variables from the webapp. Keeps the v4 IPC catalogs, ServerBackgroundWorker, and the still-used CHECKPOINT_THRESHOLD_IN_MS.
1 parent 5d13224 commit 385f82e

2 files changed

Lines changed: 2 additions & 829 deletions

File tree

apps/webapp/app/env.server.ts

Lines changed: 0 additions & 46 deletions
Original file line numberDiff line numberDiff line change
@@ -612,7 +612,6 @@ const EnvironmentSchema = z
612612
// log-only mode before enforcement.
613613
DEPRECATE_V3_CLI_DEPLOYS_ENABLED: z.string().default("0"),
614614

615-
616615
// Verify the deploy image exists before promoting. Disable for out-of-band/air-gapped push. ECR only.
617616
DEPLOY_IMAGE_VERIFICATION_ENABLED: BoolEnv.default(true),
618617

@@ -646,11 +645,6 @@ const EnvironmentSchema = z
646645
EVENTS_MEMORY_PRESSURE_THRESHOLD: z.coerce.number().int().default(5000),
647646
EVENTS_LOAD_SHEDDING_THRESHOLD: z.coerce.number().int().default(100000),
648647
EVENTS_LOAD_SHEDDING_ENABLED: z.string().default("1"),
649-
SHARED_QUEUE_CONSUMER_POOL_SIZE: z.coerce.number().int().default(10),
650-
SHARED_QUEUE_CONSUMER_INTERVAL_MS: z.coerce.number().int().default(100),
651-
SHARED_QUEUE_CONSUMER_NEXT_TICK_INTERVAL_MS: z.coerce.number().int().default(100),
652-
SHARED_QUEUE_CONSUMER_EMIT_RESUME_DEPENDENCY_TIMEOUT_MS: z.coerce.number().int().default(1000),
653-
SHARED_QUEUE_CONSUMER_RESOLVE_PAYLOADS_BATCH_SIZE: z.coerce.number().int().default(25),
654648

655649
MANAGED_WORKER_SECRET: z.string().default("managed-secret"),
656650

@@ -770,49 +764,9 @@ const EnvironmentSchema = z
770764

771765
LOOPS_API_KEY: z.string().optional(),
772766
ATTIO_API_KEY: z.string().optional(),
773-
MARQS_DISABLE_REBALANCING: BoolEnv.default(false),
774-
MARQS_VISIBILITY_TIMEOUT_MS: z.coerce
775-
.number()
776-
.int()
777-
.default(60 * 1000 * 15),
778-
MARQS_SHARED_QUEUE_LIMIT: z.coerce.number().int().default(1000),
779-
MARQS_MAXIMUM_QUEUE_PER_ENV_COUNT: z.coerce.number().int().default(50),
780-
MARQS_DEV_QUEUE_LIMIT: z.coerce.number().int().default(1000),
781-
MARQS_MAXIMUM_NACK_COUNT: z.coerce.number().int().default(64),
782-
MARQS_CONCURRENCY_LIMIT_BIAS: z.coerce.number().default(0.75),
783-
MARQS_AVAILABLE_CAPACITY_BIAS: z.coerce.number().default(0.3),
784-
MARQS_QUEUE_AGE_RANDOMIZATION_BIAS: z.coerce.number().default(0.25),
785-
MARQS_REUSE_SNAPSHOT_COUNT: z.coerce.number().int().default(0),
786-
MARQS_MAXIMUM_ENV_COUNT: z.coerce.number().int().optional(),
787-
MARQS_SHARED_WORKER_QUEUE_CONSUMER_INTERVAL_MS: z.coerce.number().int().default(250),
788-
MARQS_SHARED_WORKER_QUEUE_MAX_MESSAGE_COUNT: z.coerce.number().int().default(10),
789-
790-
MARQS_SHARED_WORKER_QUEUE_EAGER_DEQUEUE_ENABLED: z.string().default("0"),
791-
MARQS_WORKER_ENABLED: z.string().default("0"),
792-
MARQS_WORKER_COUNT: z.coerce.number().int().default(2),
793-
MARQS_WORKER_CONCURRENCY_LIMIT: z.coerce.number().int().default(50),
794-
MARQS_WORKER_CONCURRENCY_TASKS_PER_WORKER: z.coerce.number().int().default(5),
795-
MARQS_WORKER_POLL_INTERVAL_MS: z.coerce.number().int().default(100),
796-
MARQS_WORKER_IMMEDIATE_POLL_INTERVAL_MS: z.coerce.number().int().default(100),
797-
MARQS_WORKER_SHUTDOWN_TIMEOUT_MS: z.coerce.number().int().default(60_000),
798-
MARQS_SHARED_WORKER_QUEUE_COOLOFF_COUNT_THRESHOLD: z.coerce.number().int().default(10),
799-
MARQS_SHARED_WORKER_QUEUE_COOLOFF_PERIOD_MS: z.coerce.number().int().default(5_000),
800767

801768
PROD_TASK_HEARTBEAT_INTERVAL_MS: z.coerce.number().int().optional(),
802769

803-
V2_MARQS_ENABLED: z.string().default("0"),
804-
V2_MARQS_CONSUMER_POOL_ENABLED: z.string().default("0"),
805-
V2_MARQS_CONSUMER_POOL_SIZE: z.coerce.number().int().default(10),
806-
V2_MARQS_CONSUMER_POLL_INTERVAL_MS: z.coerce.number().int().default(1000),
807-
V2_MARQS_QUEUE_SELECTION_COUNT: z.coerce.number().int().default(36),
808-
V2_MARQS_VISIBILITY_TIMEOUT_MS: z.coerce
809-
.number()
810-
.int()
811-
.default(60 * 1000 * 15),
812-
V2_MARQS_DEFAULT_ENV_CONCURRENCY: z.coerce.number().int().default(100),
813-
V2_MARQS_VERBOSE: z.string().default("0"),
814-
V3_MARQS_CONCURRENCY_MONITOR_ENABLED: z.string().default("0"),
815-
V2_MARQS_CONCURRENCY_MONITOR_ENABLED: z.string().default("0"),
816770
/* Usage settings */
817771
USAGE_EVENT_URL: z.string().optional(),
818772
PROD_USAGE_HEARTBEAT_INTERVAL_MS: z.coerce.number().int().optional(),

0 commit comments

Comments
 (0)