I did a bad change... in a flowcb, it should be on_cleanup, but elsew…

…here it should be cleanup() now redis and disk implmentations are consistent and called from flowcb on_cleanup
MetPX · Aug 1, 2023 · 8432616 · 8432616
1 parent 157fdde
commit 8432616
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sarracenia/redisqueue.py b/sarracenia/redisqueue.py
@@ -228,7 +228,7 @@ def put(self, message_list):
             logger.debug("rpush to list %s %s" % (self.key_name_new, message))
             self.redis.rpush(self.key_name_new, self._msgToJSON(message))
 
-    def on_cleanup(self):
+    def cleanup(self):
         """
         remove statefiles.
         """