test update

Author: anistark

RedisScheduler/RedisScheduler.py

@@ -82,17 +82,18 @@ def subscribe_event(self, subscribe_channel='__keyevent@0__:expired', handler='s
                 print(' >> expired key : '+str(expired_key))
                 shadow_key = '_%s' % expired_key
                 try:
-                    expired_key_value = self.redis_client.get(shadow_key)
-                    print(' + -- in 3 -- + ')
-                    if expired_key_value:
-                        print(' + -- in 4 -- + ')
-                        expired_key_json = json.loads(self.get_key(expired_key_value))
-                        print(' vv expired key value vv ')
-                        print(expired_key_json)
-                        if expired_key_json:
-                            print(' + -- in 5 -- + ')
-                            self.send_to_sqs(expired_key_json)
-                            print(' + -- in 6 -- + ')
+                    if shadow_key:
+                        expired_key_value = self.redis_client.get(shadow_key)
+                        print(' + -- in 3 -- + ')
+                        if expired_key_value:
+                            print(' + -- in 4 -- + ')
+                            expired_key_json = json.loads(self.get_key(expired_key_value))
+                            print(' vv expired key value vv ')
+                            print(expired_key_json)
+                            if expired_key_json:
+                                print(' + -- in 5 -- + ')
+                                self.send_to_sqs(expired_key_json)
+                                print(' + -- in 6 -- + ')
                 except Exception as e:
                     print(' + -- in 8 -- + ')
                     print(e)

RedisScheduler/__init__.py

@@ -1,5 +1,5 @@
 __author__ = 'anistark'
-__version__ = '1.2.9'
+__version__ = '1.2.10'
 __title__ = 'RedisScheduler'
 
 # Importing Classes