wip

ruby/lib/ci/queue/redis/worker.rb

@@ -60,12 +60,29 @@ def poll
           # only the master should perform this check because otherwise we will DDoS Redis when all workers
           # try to fetch the processed tests at the same time
           if master?
+            executed_tests = redis.smembers(key('success-reports')) + redis.hkeys(key('error-reports'))
+            ids = @index.keys.map { |id| id.dup.force_encoding(Encoding::BINARY) }
+            missing_tests = ids - executed_tests
 
-            if exhausted? &&
-                (missing_tests = @index.keys - (redis.smembers(key('success-reports')) + redis.hkeys(key('error-reports')))) &&
-                missing_tests.size > 0
+            if exhausted? && missing_tests.size > 0
               puts "ci-queue did not process all tests!"
               puts missing_tests.inspect
+
+              puts "--------------------------------"
+
+              missing_tests.each do |test|
+                puts test.inspect
+              end
+
+              puts "--------------------------------"
+              foo = executed_tests - ids
+              puts foo.inspect
+              puts "--------------------------------"
+
+              foo.each do |test|
+                puts test.inspect
+              end
+
             end
           end