diff --git a/rrrspec-server/lib/rrrspec/server/worker_runner.rb b/rrrspec-server/lib/rrrspec/server/worker_runner.rb
index dee3115..961dd87 100644
--- a/rrrspec-server/lib/rrrspec/server/worker_runner.rb
+++ b/rrrspec-server/lib/rrrspec/server/worker_runner.rb
@@ -178,9 +178,14 @@ def cleaning_process(logger, taskset, cancel_watcher_pid, pid_to_slave_number)
 
       def work
         @worker.update_current_taskset(nil)
-        taskset = @worker.dequeue_taskset
-        worker_log = WorkerLog.create(@worker, taskset)
-        logger = TimedLogger.new(worker_log)
+
+        while true do
+          taskset = @worker.dequeue_taskset
+          worker_log = WorkerLog.create(@worker, taskset)
+          logger = TimedLogger.new(worker_log)
+
+          break if taskset.status == 'running'
+        end
 
         check = proc do
           unless taskset.status == 'running'