Add timeout to query store rebuild wait

j-maynard · j-maynard · commit cb5c01275472 · 2026-05-05T13:33:47.000+01:00
diff --git a/src/controllers/revision.ts b/src/controllers/revision.ts
@@ -452,9 +452,13 @@ export const withdrawFromPublication = async (req: Request, res: Response, next:
   }
 };
 
+const MAX_TIME_OUT = 30 * 60 * 1000;
+const INCREMENT = 10000;
 async function rebuildQueryStoreAfterCubeBuild(build: BuildLog, revision: Revision): Promise<void> {
-  while (!CompleteStatus.includes(build.status)) {
-    await sleep(10000);
+  let timeout = 0;
+  while (timeout <= MAX_TIME_OUT || !CompleteStatus.includes(build.status)) {
+    await sleep(INCREMENT);
+    timeout += INCREMENT;
     await build.reload();
   }
 

Original file line number	Diff line number	Diff line change
`@@ -452,9 +452,13 @@ export const withdrawFromPublication = async (req: Request, res: Response, next:`
`452`	`452`	`}`
`453`	`453`	`};`
`454`	`454`
	`455`	`+const MAX_TIME_OUT = 30 * 60 * 1000;`
	`456`	`+const INCREMENT = 10000;`
`455`	`457`	`async function rebuildQueryStoreAfterCubeBuild(build: BuildLog, revision: Revision): Promise<void> {`
`456`		`- while (!CompleteStatus.includes(build.status)) {`
`457`		`- await sleep(10000);`
	`458`	`+ let timeout = 0;`
	`459`	`+ while (timeout <= MAX_TIME_OUT \|\| !CompleteStatus.includes(build.status)) {`
	`460`	`+ await sleep(INCREMENT);`
	`461`	`+ timeout += INCREMENT;`
`458`	`462`	`await build.reload();`
`459`	`463`	`}`
`460`	`464`