ensure retry_name is set for redis case

Author: petersilva

sarracenia/flowcb/retry.py

@@ -182,7 +182,9 @@ def on_start(self) -> None:
         if self.o.retry_driver == 'redis':
             from sarracenia.redisqueue import RedisQueue
             self.download_retry = RedisQueue(self.o, 'work_retry')
+            self.download_retry_name = self.download_retry.getName()
             self.post_retry = RedisQueue(self.o, 'post_retry')
+            self.post_retry_name = self.post_retry.getName()
         else:
             from sarracenia.diskqueue import DiskQueue
             self.download_retry_name = 'work_retry_%02d' % self.o.no

sarracenia/redisqueue.py

@@ -111,6 +111,8 @@ def __init__(self, options, name):
 
         # initialize ages and message counts
 
+    def getName(self) -> str:
+        return self.key_name
 
     def __len__(self) -> int:
         """Returns the total number of messages in the RedisQueue.