Cleanup changes

NeonGeckoCom · Jul 26, 2023 · 5a2d6f0 · 5a2d6f0
1 parent 125b606
commit 5a2d6f0
Showing 1 changed file with 16 additions and 17 deletions.
diff --git a/neon_mq_connector/connector.py b/neon_mq_connector/connector.py
@@ -218,16 +218,16 @@ def __basic_configurable_properties(self) -> Dict[str, Any]:
         self.service_configurable_properties()
         """
         return {
-                'sync_period': 10,  # in seconds
-                'observe_period': 20,  # in seconds
-                'vhost_prefix': '',  # Could be used for scalability purposes
-                'default_testing_prefix': 'test',
-                'testing_envs': (f'{self.service_name.upper()}_TESTING',
-                                 'MQ_TESTING',),  # order matters
-                'testing_prefix_envs': (f'{self.service_name.upper()}'
-                                        f'_TESTING_PREFIX',
-                                        'MQ_TESTING_PREFIX',)  # order matters
-                }
+            'sync_period': 10,  # in seconds
+            'observe_period': 20,  # in seconds
+            'vhost_prefix': '',  # Could be used for scalability purposes
+            'default_testing_prefix': 'test',
+            'testing_envs': (f'{self.service_name.upper()}_TESTING',
+                             'MQ_TESTING',),  # order matters
+            'testing_prefix_envs': (f'{self.service_name.upper()}'
+                                    f'_TESTING_PREFIX',
+                                    'MQ_TESTING_PREFIX',)  # order matters
+        }
 
     @property
     def service_configurable_properties(self) -> Dict[str, Any]:
@@ -450,13 +450,12 @@ def send_message(self,
             else:
                 LOG.debug(f'Sending {exchange_type} request to exchange '
                           f'{exchange}')
-                msg_id = self.emit_mq_message(
-                    mq_conn,
-                    queue=queue,
-                    request_data=request_data,
-                    exchange=exchange,
-                    exchange_type=exchange_type,
-                    expiration=expiration)
+                msg_id = self.emit_mq_message(mq_conn,
+                                              queue=queue,
+                                              request_data=request_data,
+                                              exchange=exchange,
+                                              exchange_type=exchange_type,
+                                              expiration=expiration)
         LOG.info(f'Message propagated, id={msg_id}')
         return msg_id