Add sleep to analyze loop (metlo-labs#88)

akshay288 · web-flow · commit 3ac6cce4fc2e · 2022-11-08T16:26:15.000-08:00
diff --git a/backend/src/analyze-traces.ts b/backend/src/analyze-traces.ts
@@ -68,6 +68,8 @@ WHERE
   "apiEndpointUuid" = $1
 `
 
+const sleep = (ms: number) => new Promise(res => setTimeout(res, ms))
+
 const getQueuedApiTrace = async (): Promise<{
   trace: QueuedApiTrace
   ctx: MetloContext
@@ -284,6 +286,8 @@ const analyzeTraces = async (): Promise<void> => {
             await generateEndpoint(ctx, trace, queryRunner)
           }
         }
+      } else {
+        await sleep(50)
       }
     } catch (err) {
       console.error(`Encountered error while analyzing traces: ${err}`)

Original file line number	Diff line number	Diff line change
`@@ -68,6 +68,8 @@ WHERE`
`68`	`68`	`"apiEndpointUuid" = $1`
`69`	`69`	`
`70`	`70`
	`71`	`+const sleep = (ms: number) => new Promise(res => setTimeout(res, ms))`
	`72`	`+`
`71`	`73`	`const getQueuedApiTrace = async (): Promise<{`
`72`	`74`	`trace: QueuedApiTrace`
`73`	`75`	`ctx: MetloContext`
`@@ -284,6 +286,8 @@ const analyzeTraces = async (): Promise<void> => {`
`284`	`286`	`await generateEndpoint(ctx, trace, queryRunner)`
`285`	`287`	`}`
`286`	`288`	`}`
	`289`	`+ } else {`
	`290`	`+ await sleep(50)`
`287`	`291`	`}`
`288`	`292`	`} catch (err) {`
`289`	`293`	console.error(`Encountered error while analyzing traces: ${err}`)