Skip to content

Commit 84c6593

Browse files
authored
Merge pull request #374 from Shopify/revert-367-cbruckmayer/reduce-key-size
Revert "Reduce Redis key size"
2 parents 3de93c6 + 0a190e4 commit 84c6593

7 files changed

Lines changed: 7 additions & 61 deletions

File tree

ruby/lib/ci/queue/redis.rb

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@
1111
require 'ci/queue/redis/supervisor'
1212
require 'ci/queue/redis/grind_supervisor'
1313
require 'ci/queue/redis/test_time_record'
14-
require 'ci/queue/redis/key_shortener'
1514

1615
module CI
1716
module Queue

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -214,7 +214,7 @@ def measure
214214
end
215215

216216
def key(*args)
217-
KeyShortener.key(config.build_id, *args)
217+
['build', build_id, *args].join(':')
218218
end
219219

220220
def build_id

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -139,7 +139,7 @@ def record_stats(stats, pipeline: redis)
139139
end
140140

141141
def key(*args)
142-
KeyShortener.key(config.build_id, *args)
142+
['build', config.build_id, *args].join(':')
143143
end
144144
end
145145
end

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ def pop_warnings
5252
attr_reader :redis, :config
5353

5454
def key(*args)
55-
KeyShortener.key(config.build_id, *args)
55+
['build', config.build_id, *args].join(':')
5656
end
5757

5858
def record_stats(stats, pipeline: redis)

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

Lines changed: 0 additions & 53 deletions
This file was deleted.

ruby/test/ci/queue/redis_test.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -207,9 +207,9 @@ def test_acknowledge_returns_false_if_the_test_was_picked_up_by_another_worker
207207
end
208208

209209
def test_workers_register
210-
assert_equal 1, @redis.scard(CI::Queue::Redis::KeyShortener.key('42', 'workers'))
210+
assert_equal 1, @redis.scard(('build:42:workers'))
211211
worker(2)
212-
assert_equal 2, @redis.scard(CI::Queue::Redis::KeyShortener.key('42', 'workers'))
212+
assert_equal 2, @redis.scard(('build:42:workers'))
213213
end
214214

215215
def test_timeout_warning

ruby/test/integration/minitest_redis_test.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -139,7 +139,7 @@ def test_debug_log
139139
)
140140
end
141141

142-
assert_includes File.read(log_file.path), 'INFO -- : Finished \'["exists", "b:c4ca4238:w:1:q"]\': 0'
142+
assert_includes File.read(log_file.path), 'INFO -- : Finished \'["exists", "build:1:worker:1:queue"]\': 0'
143143
assert_empty err
144144
result = normalize(out.lines.last.strip)
145145
assert_equal '--- Ran 11 tests, 8 assertions, 2 failures, 1 errors, 1 skips, 4 requeues in X.XXs', result
@@ -444,7 +444,7 @@ def test_retry_fails_when_test_run_is_expired
444444
assert_equal 'Ran 100 tests, 100 assertions, 0 failures, 0 errors, 0 skips, 0 requeues in X.XXs', output
445445

446446
one_day = 60 * 60 * 24
447-
key = CI::Queue::Redis::KeyShortener.key("1", "created-at")
447+
key = ['build', "1", "created-at"].join(':')
448448
@redis.set(key, Time.now - one_day)
449449

450450
out, err = capture_subprocess_io do

0 commit comments

Comments
 (0)