We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7ded3f7 commit feda99dCopy full SHA for feda99d
1 file changed
dispatcher/main.go
@@ -12,8 +12,14 @@ var (
12
reserveRAM = resourcemanager.ReserveRAM
13
releaseRAM = resourcemanager.ReleaseRAM
14
execute = executor.Execute
15
+ workerActive bool
16
)
17
18
+// resetQueueStateForTests resets dispatcher worker state between tests.
19
+func resetQueueStateForTests() {
20
+ workerActive = false
21
+}
22
+
23
func normalizeRequest(req models.Request) models.Request {
24
if req.Timeout == 0 {
25
req.Timeout = config.Config.Limits.DefaultTimeout
0 commit comments