File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -117,10 +117,10 @@ def _publish(self, data):
117
117
return self .redis .publish (self .channel , pickle .dumps (data ))
118
118
except redis .exceptions .RedisError :
119
119
if retry :
120
- logger .error ('Cannot publish to redis... retrying' )
120
+ logger .exception ('Cannot publish to redis... retrying' )
121
121
retry = False
122
122
else :
123
- logger .error ('Cannot publish to redis... giving up' )
123
+ logger .exception ('Cannot publish to redis... giving up' )
124
124
break
125
125
126
126
def _redis_listen_with_retries (self ):
@@ -134,7 +134,7 @@ def _redis_listen_with_retries(self):
134
134
retry_sleep = 1
135
135
yield from self .pubsub .listen ()
136
136
except redis .exceptions .RedisError :
137
- logger .error ('Cannot receive from redis... '
137
+ logger .exception ('Cannot receive from redis... '
138
138
'retrying in {} secs' .format (retry_sleep ))
139
139
connect = True
140
140
time .sleep (retry_sleep )
You can’t perform that action at this time.
0 commit comments