File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -117,10 +117,10 @@ def _publish(self, data):
117117 return self .redis .publish (self .channel , pickle .dumps (data ))
118118 except redis .exceptions .RedisError :
119119 if retry :
120- logger .error ('Cannot publish to redis... retrying' )
120+ logger .exception ('Cannot publish to redis... retrying' )
121121 retry = False
122122 else :
123- logger .error ('Cannot publish to redis... giving up' )
123+ logger .exception ('Cannot publish to redis... giving up' )
124124 break
125125
126126 def _redis_listen_with_retries (self ):
@@ -134,7 +134,7 @@ def _redis_listen_with_retries(self):
134134 retry_sleep = 1
135135 yield from self .pubsub .listen ()
136136 except redis .exceptions .RedisError :
137- logger .error ('Cannot receive from redis... '
137+ logger .exception ('Cannot receive from redis... '
138138 'retrying in {} secs' .format (retry_sleep ))
139139 connect = True
140140 time .sleep (retry_sleep )
You can’t perform that action at this time.
0 commit comments