Fix

ESGF · Aug 30, 2024 · 3e7f0c9 · 3e7f0c9
1 parent aa8a9b2
commit 3e7f0c9
Show file tree

Hide file tree

Showing 3 changed files with 27 additions and 11 deletions.
diff --git a/esgf-consumer/esgf_consumer/__init__.py b/esgf-consumer/esgf_consumer/__init__.py
@@ -10,14 +10,21 @@
 from aiokafka.errors import KafkaError
 from esgf_consumer.collection import ensure_collection
 from esgf_consumer.consumers import get_consumer
-from esgf_consumer.exceptions import (ESGFConsumerNotImplementedPayloadError,
-                                      ESGFConsumerUnknownPayloadError)
+from esgf_consumer.exceptions import (
+    ESGFConsumerNotImplementedPayloadError,
+    ESGFConsumerUnknownPayloadError,
+)
 from esgf_consumer.items import create_item, hard_delete_item, update_item
 from esgf_consumer.producers import get_producer
 from esgf_playground_utils.config.kafka import Settings
-from esgf_playground_utils.models.kafka import (CreatePayload, Error,
-                                                ErrorType, KafkaEvent,
-                                                RevokePayload, UpdatePayload)
+from esgf_playground_utils.models.kafka import (
+    CreatePayload,
+    Error,
+    ErrorType,
+    KafkaEvent,
+    RevokePayload,
+    UpdatePayload,
+)
 from pydantic import ValidationError
 
 logging.getLogger().setLevel(logging.DEBUG)

diff --git a/esgf-generator/esgf_generator/__init__.py b/esgf-generator/esgf_generator/__init__.py
@@ -6,8 +6,11 @@
 
 import httpx
 from esgf_generator.data import CHOICES
-from esgf_generator.static_generators import (generate_datetime,
-                                              generate_geometry, instance_id)
+from esgf_generator.static_generators import (
+    generate_datetime,
+    generate_geometry,
+    instance_id,
+)
 from esgf_playground_utils.models.item import ESGFItem, ESGFItemProperties
 from polyfactory import PostGenerated
 from polyfactory.factories.pydantic_factory import ModelFactory

diff --git a/esgf-transaction-api/esgf_transaction_api/main.py b/esgf-transaction-api/esgf_transaction_api/main.py
@@ -6,10 +6,16 @@
 
 import aiokafka
 from esgf_playground_utils.config.kafka import Settings
-from esgf_playground_utils.models.kafka import (Auth, CreatePayload, Data,
-                                                KafkaEvent, Metadata,
-                                                Publisher, RevokePayload,
-                                                UpdatePayload)
+from esgf_playground_utils.models.kafka import (
+    Auth,
+    CreatePayload,
+    Data,
+    KafkaEvent,
+    Metadata,
+    Publisher,
+    RevokePayload,
+    UpdatePayload,
+)
 from fastapi import FastAPI, HTTPException, Request
 from stac_pydantic.item import Item
 from stac_pydantic.item_collection import ItemCollection