Skip to content

Commit 9f5dea4

Browse files
committed
wip
1 parent 3d0ad0d commit 9f5dea4

1 file changed

Lines changed: 20 additions & 3 deletions

File tree

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

Lines changed: 20 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -60,12 +60,29 @@ def poll
6060
# only the master should perform this check because otherwise we will DDoS Redis when all workers
6161
# try to fetch the processed tests at the same time
6262
if master?
63+
executed_tests = redis.smembers(key('success-reports')) + redis.hkeys(key('error-reports'))
64+
ids = @index.keys.map { |id| id.force_encoding(Encoding::BINARY) }
65+
missing_tests = ids - executed_tests
6366

64-
if exhausted? &&
65-
(missing_tests = @index.keys - (redis.smembers(key('success-reports')) + redis.hkeys(key('error-reports')))) &&
66-
missing_tests.size > 0
67+
if exhausted? && missing_tests.size > 0
6768
puts "ci-queue did not process all tests!"
6869
puts missing_tests.inspect
70+
71+
puts "--------------------------------"
72+
73+
missing_tests.each do |test|
74+
puts test.inspect
75+
end
76+
77+
puts "--------------------------------"
78+
foo = executed_tests - ids
79+
puts foo.inspect
80+
puts "--------------------------------"
81+
82+
foo.each do |test|
83+
puts test.inspect
84+
end
85+
6986
end
7087
end
7188

0 commit comments

Comments
 (0)