Skip to content

Commit f9b3fc9

Browse files
author
Juuso Mäyränen
committed
Remove debug output
1 parent b251fb3 commit f9b3fc9

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

lib/logstash/inputs/redis.rb

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -288,7 +288,6 @@ def pattern_list_batch_processor(redis, output_queue, key)
288288
while items_left > 0
289289
limit = [items_left, @batch_count].min
290290
processed = process_batch(redis, output_queue, key, limit, 0)
291-
@logger.warn("Got batch size #{processed} for #{key}")
292291
if processed.zero? || processed < limit
293292
return
294293
end
@@ -298,7 +297,6 @@ def pattern_list_batch_processor(redis, output_queue, key)
298297

299298
# private
300299
def pattern_list_worker_consume(output_queue, key)
301-
@logger.debug("Launched worker for #{key}")
302300
begin
303301
redis ||= connect
304302
@pattern_list_processor.call(redis, output_queue, key)
@@ -309,7 +307,6 @@ def pattern_list_worker_consume(output_queue, key)
309307
ensure
310308
redis.quit rescue nil
311309
end
312-
@logger.warn("Exit worker for #{key}")
313310
end
314311

315312
# private

0 commit comments

Comments
 (0)