Pre-merge code cleanup

src/dlt/connector/service/DltConnectorServiceServicerImpl.py

@@ -118,9 +118,9 @@ class DltConnectorServiceServicerImpl(DltConnectorServiceServicer):
         data_json : Optional[str] = None
     ) -> None:
         dlt_record_id = DltRecordId()
-        dlt_record_id.domain_uuid.uuid = dlt_domain_uuid  # pylint: disable=no-member
-        dlt_record_id.type = dlt_record_type
-        dlt_record_id.record_uuid.uuid = dlt_record_uuid  # pylint: disable=no-member
+        dlt_record_id.domain_uuid.uuid = dlt_domain_uuid    # pylint: disable=no-member
+        dlt_record_id.type             = dlt_record_type
+        dlt_record_id.record_uuid.uuid = dlt_record_uuid    # pylint: disable=no-member
 
         str_dlt_record_id = grpc_message_to_json_string(dlt_record_id)
         LOGGER.debug('[_record_entity] sent dlt_record_id = {:s}'.format(str_dlt_record_id))
@@ -132,7 +132,7 @@ class DltConnectorServiceServicerImpl(DltConnectorServiceServicer):
         LOGGER.debug('[_record_entity] exists = {:s}'.format(str(exists)))
 
         dlt_record = DltRecord()
-        dlt_record.record_id.CopyFrom(dlt_record_id)  # pylint: disable=no-member
+        dlt_record.record_id.CopyFrom(dlt_record_id)    # pylint: disable=no-member
         if delete and exists:
             dlt_record.operation = DltRecordOperationEnum.DLTRECORDOPERATION_DELETE
         elif not delete and exists:

src/dlt/connector/service/__main__.py

@@ -42,7 +42,7 @@ async def main():
         get_env_var_name(ServiceNameEnum.CONTEXT, ENVVAR_SUFIX_SERVICE_PORT_GRPC),
     ])
 
-    signal.signal(signal.SIGINT, signal_handler)
+    signal.signal(signal.SIGINT,  signal_handler)
     signal.signal(signal.SIGTERM, signal_handler)
 
     LOGGER.info('Starting...')