bin/notify_inbound_failures_job 🔗
@@ -156,7 +156,7 @@ EM.run do
redis = EM::Hiredis.connect
EMPromise.resolve(
- redis.mget("bw_last_msg_failed_date", "bw_last_msg_failed_id")
+ redis.mget("bw_last_message_failed_time", "bw_last_message_failed_id")
).then { |(last_msg_date, last_msg_id)|
thirty_mins_ago = (Time.now - 30 * 60).strftime("%Y-%m-%dT%H:%M:%S.%LZ")
last_msg_date ||= thirty_mins_ago