Skip to content

Commit 9d1f7d4

Browse files
committed
Updated error logs for Redis APIs.
Signed-off-by: Azeem Sajid <azeem.sajid@gmail.com>
1 parent 1384b7e commit 9d1f7d4

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

lib/fluent/plugin/in_http_cwm.rb

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ def initialize
8080
end
8181

8282
def set_up_redis
83-
log.info("Connecting with Redis [#{@redis_config.host}:#{redis_config.port}]")
83+
log.info("Connecting with Redis [#{@redis_config.host}:#{@redis_config.port}]")
8484
@redis = Redis.new(host: @redis_config.host, port: @redis_config.port)
8585
ready = false
8686
until ready
@@ -89,7 +89,7 @@ def set_up_redis
8989
@redis.ping
9090
ready = true
9191
rescue StandardError => e
92-
log.error("ERROR: #{e}")
92+
log.error("Unable to connect to Redis server! ERROR: '#{e}'. Retrying...")
9393
end
9494
end
9595
end
@@ -153,7 +153,7 @@ def update_deployment_last_action(deploymentid)
153153
@redis.set(key, curdt.strftime(FMT_DATETIME))
154154
end
155155
rescue StandardError => e
156-
log.debug("ERROR: #{e}")
156+
log.error("Unable to update last action! ERROR: '#{e}'.")
157157
end
158158
end
159159

@@ -236,7 +236,7 @@ def flush_api_metrics
236236

237237
log.debug('Flushing complete!')
238238
rescue StandardError => e
239-
log.debug("ERROR: #{e}")
239+
log.error("Unable to flush metrics! ERROR: '#{e}'.")
240240
end
241241
end
242242
end

0 commit comments

Comments
 (0)