diff --git a/apps/api/src/controllers/v2/concurrency-check.ts b/apps/api/src/controllers/v2/concurrency-check.ts
new file mode 100644
index 000000000..27a71d586
--- /dev/null
+++ b/apps/api/src/controllers/v2/concurrency-check.ts
@@ -0,0 +1,37 @@
+import {
+  AuthCreditUsageChunkFromTeam,
+  ConcurrencyCheckParams,
+  ConcurrencyCheckResponse,
+  RequestWithAuth,
+} from "./types";
+import { Response } from "express";
+import { redisEvictConnection } from "../../../src/services/redis";
+import { getACUCTeam } from "../auth";
+import { RateLimiterMode } from "../../types";
+
+// Basically just middleware and error wrapping
+export async function concurrencyCheckController(
+  req: RequestWithAuth<ConcurrencyCheckParams, undefined, undefined>,
+  res: Response<ConcurrencyCheckResponse>,
+) {
+  let otherACUC: AuthCreditUsageChunkFromTeam | null = null;
+  if (!req.acuc.is_extract) {
+    otherACUC = await getACUCTeam(req.auth.team_id, false, true, RateLimiterMode.Extract);
+  } else {
+    otherACUC = await getACUCTeam(req.auth.team_id, false, true, RateLimiterMode.Crawl);
+  }
+
+  const concurrencyLimiterKey = "concurrency-limiter:" + req.auth.team_id;
+  const now = Date.now();
+  const activeJobsOfTeam = await redisEvictConnection.zrangebyscore(
+    concurrencyLimiterKey,
+    now,
+    Infinity,
+  );
+
+  return res.status(200).json({
+    success: true,
+    concurrency: activeJobsOfTeam.length,
+    maxConcurrency: Math.max(req.acuc.concurrency, otherACUC?.concurrency ?? 0),
+  });
+}