test update

Author: anistark

RedisScheduler/RedisScheduler.py

@@ -22,6 +22,30 @@ def __init__(self, host='localhost', port=6379, path=None, db=0, password=None):
             print(e)
 
 
+    def set_sqs_keys(self, access_key, secret_key, queue_name, region='ap-south-1'):
+        try:
+            self.boto3_client = boto3.client(
+                    'sqs',
+                    aws_access_key_id=access_key,
+                    aws_secret_access_key=secret_key,
+                    region_name=region
+            )
+            self.queue_url = self.boto3_client.get_queue_url(QueueName=queue_name)['QueueUrl']
+        except Exception as e:
+            print(e)
+            print('^^ Some Error in connection to aws sqs ^^')
+
+
+    def get_timedelta(self, timestamp):
+        # current_time = datetime.now(pytz.timezone('UTC')).strftime('%Y-%m-%d %H:%M:%S%z')
+        current_time = datetime.now(tzutc())
+        # parsed_timestamp = datetime.strptime(''.join(timestamp.rsplit(':', 1)), '%Y-%m-%dT%H:%M:%S%z')
+        parsed_timestamp = dateutil.parser.parse(timestamp)
+        # parsed_timestamp_in_utc = datetime_obj.astimezone(tz=timezone.utc)
+        parsed_timestamp_in_utc = parsed_timestamp.astimezone(tzutc())
+        return (parsed_timestamp_in_utc-current_time).total_seconds()
+
+
     def add_key(self, key, value, ttl=604800):
         try:
             print(' -- Adding Key -- ')
@@ -125,41 +149,17 @@ def start_listening(self, subscribe_channel='__keyevent@0__:expired', handler='s
         print(' -- listener initiated -- ')
 
 
-    def get_timedelta(self, timestamp):
-        # current_time = datetime.now(pytz.timezone('UTC')).strftime('%Y-%m-%d %H:%M:%S%z')
-        current_time = datetime.now(tzutc())
-        # parsed_timestamp = datetime.strptime(''.join(timestamp.rsplit(':', 1)), '%Y-%m-%dT%H:%M:%S%z')
-        parsed_timestamp = dateutil.parser.parse(timestamp)
-        # parsed_timestamp_in_utc = datetime_obj.astimezone(tz=timezone.utc)
-        parsed_timestamp_in_utc = parsed_timestamp.astimezone(tzutc())
-        return (parsed_timestamp_in_utc-current_time).total_seconds()
-
-
-    def set_sqs_keys(self, access_key, secret_key, queue_name, region='ap-south-1'):
-        try:
-            self.boto3_client = boto3.client(
-                    'sqs',
-                    aws_access_key_id=access_key,
-                    aws_secret_access_key=secret_key,
-                    region_name=region
-            )
-            self.queue_url = self.boto3_client.get_queue_url(QueueName=queue_name)['QueueUrl']
-        except Exception as e:
-            print(e)
-            print('^^ Some Error in connection to aws sqs ^^')
-
-
-    def send_to_sqs(self, msg):
-        print('-- Sending to SQS --')
-        try:
-            response = self.boto3_client.send_message(
-                    QueueUrl=self.queue_url,
-                    MessageBody=json.dumps(msg)
-            )
-            print('-- Sent to SQS --')
-        except Exception as e:
-            print(e)
-            print('^^ Some Error in sending to sqs ^^')
+    # def send_to_sqs(self, msg):
+    #     print('-- Sending to SQS --')
+    #     try:
+    #         response = self.boto3_client.send_message(
+    #                 QueueUrl=self.queue_url,
+    #                 MessageBody=json.dumps(msg)
+    #         )
+    #         print('-- Sent to SQS --')
+    #     except Exception as e:
+    #         print(e)
+    #         print('^^ Some Error in sending to sqs ^^')
 
 
     # def terminate_processes(self, subscribe_channel='__keyevent@0__:expired', handler='sqs'):

RedisScheduler/__init__.py

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