Fixed imports in docker services

ESGF · Jul 18, 2024 · 1b91d6f · 1b91d6f
1 parent 15aa857
commit 1b91d6f
Show file tree

Hide file tree

Showing 7 changed files with 134 additions and 5 deletions.
diff --git a/esgf-api-ingest/esgf_api_ingest/main.py b/esgf-api-ingest/esgf_api_ingest/main.py
@@ -5,7 +5,7 @@
 
 import aiokafka
 from esgf_playground_utils.config.kafka import Settings
-from esgf_playground_utlis.models.kafka import (
+from esgf_playground_utils.models.kafka import (
     Auth,
     CreatePayload,
     Data,

diff --git a/esgf-api-ingest/poetry.lock b/esgf-api-ingest/poetry.lock
diff --git a/esgf-api-ingest/pyproject.toml b/esgf-api-ingest/pyproject.toml
@@ -10,6 +10,7 @@ python = "^3.12"
 fastapi = "^0.111.1"
 uvicorn = "^0.30.1"
 esgf-playground-utils = "0.1.0"
+aiokafka = "^0.11.0"
 
 [tool.poetry.group.black.dependencies]
 black = "^24.4.2"

diff --git a/esgf-consumer/esgf_consumer/__init__.py b/esgf-consumer/esgf_consumer/__init__.py
@@ -9,10 +9,10 @@
 import httpx
 from aiokafka.errors import KafkaError
 from esgf_playground_utils.models.kafka import Error, ErrorType, KafkaEvent
+from esgf_playground_utils.config.kafka import Settings
 from pydantic import ValidationError
 
 from esgf_consumer.collection import ensure_collection
-from esgf_consumer.config import Settings
 from esgf_consumer.consumers import get_consumer
 from esgf_consumer.items import create_item
 from esgf_consumer.producers import get_producer

diff --git a/esgf-consumer/esgf_consumer/items.py b/esgf-consumer/esgf_consumer/items.py
@@ -4,7 +4,8 @@
 import httpx
 from stac_pydantic.item import Item
 
-from esgf_consumer.config import Settings
+from esgf_playground_utils.config.kafka import Settings
+
 
 logger = logging.getLogger(__name__)
 

diff --git a/esgf-consumer/poetry.lock b/esgf-consumer/poetry.lock
diff --git a/esgf-consumer/pyproject.toml b/esgf-consumer/pyproject.toml
@@ -10,6 +10,7 @@ python = "^3.12"
 httpx = "^0.27.0"
 click = "^8.1.7"
 esgf-playground-utils = "0.1.0"
+aiokafka = "^0.11.0"
 
 [tool.poetry.group.black.dependencies]
 black = "^24.4.2"