same

williamstein · williamstein · commit 1937cf4b9057 · 2025-04-24T18:46:50.000Z
diff --git a/src/packages/database/nats/changefeeds.ts b/src/packages/database/nats/changefeeds.ts
@@ -430,7 +430,7 @@ const createNewChangefeed = async ({ query, user, nc, opts, hash }) => {
   // other "threads" doing hard work:
   while (numChangefeedsBeingCreatedAtOnce >= PARALLEL_LIMIT) {
     // TODO: This is STUPID
-    await delay(50);
+    await delay(25);
   }
   try {
     numChangefeedsBeingCreatedAtOnce += 1;

Original file line number	Diff line number	Diff line change
`@@ -430,7 +430,7 @@ const createNewChangefeed = async ({ query, user, nc, opts, hash }) => {`
`430`	`430`	`// other "threads" doing hard work:`
`431`	`431`	`while (numChangefeedsBeingCreatedAtOnce >= PARALLEL_LIMIT) {`
`432`	`432`	`// TODO: This is STUPID`
`433`		`- await delay(50);`
	`433`	`+ await delay(25);`
`434`	`434`	`}`
`435`	`435`	`try {`
`436`	`436`	`numChangefeedsBeingCreatedAtOnce += 1;`