Check we executed all tests

Author: ChrisBr

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

@@ -55,6 +55,19 @@ def poll
               sleep 0.05
             end
           end
+
+          # check we executed all tests
+          # 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?
+            missing_tests = @index.keys - redis.smembers(key('processed'))
+            puts "missing_tests: #{missing_tests.size}"
+            if exhausted? && missing_tests.size > 0
+              puts "We have not processed all tests!"
+              puts missing_tests.inspect
+            end
+          end
+
           redis.pipelined do |pipeline|
             pipeline.expire(key('worker', worker_id, 'queue'), config.redis_ttl)
             pipeline.expire(key('processed'), config.redis_ttl)