reset the worker state after request dispatching is done

Author: Anga205

dispatcher/main.go

@@ -9,11 +9,17 @@ import (
 )
 
 var (
-	reserveRAM = resourcemanager.ReserveRAM
-	releaseRAM = resourcemanager.ReleaseRAM
-	execute    = executor.Execute
+	reserveRAM   = resourcemanager.ReserveRAM
+	releaseRAM   = resourcemanager.ReleaseRAM
+	execute      = executor.Execute
+	workerActive bool
 )
 
+// resetQueueStateForTests resets dispatcher worker state between tests.
+func resetQueueStateForTests() {
+	workerActive = false
+}
+
 func normalizeRequest(req models.Request) models.Request {
 	if req.Timeout == 0 {
 		req.Timeout = config.Config.Limits.DefaultTimeout