Black and isort

Author: sturoscy-personal

.gitignore

@@ -6,4 +6,5 @@ venv
 dist
 build
 *.egg-info
-.env*
+.env*
+.pytest*

src/consumer.py

@@ -21,7 +21,9 @@ def process_messages(self, messages):
                 data = json.loads(msg.value())
                 messages_data.append(data)
             except json.JSONDecodeError as e:
-                logging.error(f"Data deserialization error at offset {msg.offset()}: {e}.")
+                logging.error(
+                    f"Data deserialization error at offset {msg.offset()}: {e}."
+                )
                 return False
         return messages_data
 
@@ -37,7 +39,9 @@ def start(self):
                 logging.info(f"Consumed {len(messages)} messages")
                 first_msg = messages[0]
                 offset = 0 if not first_msg.offset() else first_msg.offset()
-                self.seek_partition = TopicPartition(first_msg.topic(), first_msg.partition(), offset)
+                self.seek_partition = TopicPartition(
+                    first_msg.topic(), first_msg.partition(), offset
+                )
 
                 messages_data = self.process_messages(messages)
                 if not messages_data:

src/globus.py

@@ -1,8 +1,9 @@
 import logging
 import time
-import jsonpatch
 
-from globus_sdk import ClientCredentialsAuthorizer, ConfidentialAppAuthClient, SearchClient
+import jsonpatch
+from globus_sdk import (ClientCredentialsAuthorizer, ConfidentialAppAuthClient,
+                        SearchClient)
 from globus_sdk.scopes import SearchScopes
 from globus_sdk.services.search.errors import SearchAPIError
 
@@ -69,7 +70,9 @@ def ingest(self, messages_data):
     def post(self, message_data):
         item = message_data.get("data").get("payload").get("item")
         try:
-            globus_response = self.search_client.get_subject(self.esgf_index, item.get("id"))
+            globus_response = self.search_client.get_subject(
+                self.esgf_index, item.get("id")
+            )
         except SearchAPIError as e:
             if e.http_status == 404:
                 item["assets"] = self.convert_assets(item.get("assets"))
@@ -99,7 +102,9 @@ def json_patch(self, message_data):
                 value=f"Item with ID {item_id} does not exist in the index.",
             )
             return None
-        gmeta_entry = jsonpatch.apply_patch(globus_response.data.get("content"), payload.get("patch"))
+        gmeta_entry = jsonpatch.apply_patch(
+            globus_response.data.get("content"), payload.get("patch")
+        )
         return gmeta_entry
 
     def delete(self, subject):

src/settings/producer.py

@@ -1,4 +1,3 @@
-
 import logging
 import os
 import socket