fix(cubestore): Single job process don't stop after job done (#7706)

cube-js · Jan 31, 2024 · b84a345 · b84a345
1 parent 6cac9de
commit b84a345
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/rust/cubestore/cubestore/src/cluster/worker_pool.rs b/rust/cubestore/cubestore/src/cluster/worker_pool.rs
@@ -280,6 +280,10 @@ impl<C: Configurator, P: WorkerProcessing, S: ServicesTransport> WorkerProcess<C
                         break;
                     }
                 }
+
+                if P::is_single_job_process() {
+                    break;
+                }
             }
         }
     }
@@ -437,9 +441,6 @@ where
                     return 0;
                 }
             }
-            if P::is_single_job_process() {
-                return 0;
-            }
         }
     })
 }