Skip to content

Commit

Permalink
Remove debug log statements
Browse files Browse the repository at this point in the history
  • Loading branch information
TheByronHimes committed May 21, 2024
1 parent 63f9069 commit fbff351
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 19 deletions.
3 changes: 0 additions & 3 deletions src/nos/inject.py
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
#
"""Module hosting the dependency injection framework."""

import logging
from collections.abc import AsyncGenerator
from contextlib import asynccontextmanager

Expand All @@ -37,8 +36,6 @@
from nos.translators.outbound.dao import user_dao_factory
from nos.translators.outbound.event_pub import NotificationEmitter

log = logging.getLogger(__name__)


@asynccontextmanager
async def prepare_core(
Expand Down
3 changes: 0 additions & 3 deletions src/nos/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,15 +16,12 @@
"""Top-level functions for the service"""

import asyncio
import logging

from hexkit.log import configure_logging

from nos.config import Config
from nos.inject import prepare_event_subscriber, prepare_outbox_subscriber

log = logging.getLogger(__name__)


async def consume_events(run_forever: bool = True):
"""Start consuming events with kafka"""
Expand Down
13 changes: 0 additions & 13 deletions src/nos/translators/inbound/event_sub.py
Original file line number Diff line number Diff line change
Expand Up @@ -15,8 +15,6 @@
#
"""Event subscriber definition."""

import logging

from ghga_event_schemas import pydantic_ as event_schemas
from ghga_event_schemas.validation import get_validated_payload
from hexkit.custom_types import Ascii, JsonObject
Expand All @@ -27,8 +25,6 @@

from nos.ports.inbound.orchestrator import OrchestratorPort

log = logging.getLogger(__name__)


class EventSubTranslatorConfig(BaseSettings):
"""Config for the event subscriber"""
Expand Down Expand Up @@ -91,7 +87,6 @@ class EventSubTranslator(EventSubscriberProtocol):
def __init__(
self, *, config: EventSubTranslatorConfig, orchestrator: OrchestratorPort
):
log.debug("Hit __init__ in EventSubTranslator")
self.topics_of_interest = [
config.access_request_events_topic,
config.file_registered_event_topic,
Expand Down Expand Up @@ -152,13 +147,6 @@ async def _consume_validated(
self, *, payload: JsonObject, type_: Ascii, topic: Ascii, key: Ascii
) -> None:
"""Consumes an event"""
log.debug(
"Consuming event with type %s, topic %s, key %s, and payload %s",
type_,
topic,
key,
payload,
)
match type_:
case _ if type_ in (
self._config.access_request_created_event_type,
Expand Down Expand Up @@ -198,7 +186,6 @@ def __init__(
config: OutboxSubTranslatorConfig,
orchestrator: OrchestratorPort,
):
log.debug("Hit __init__ in OutboxSubTranslator")
self._config = config
self._orchestrator = orchestrator
self.event_topic = config.user_events_topic
Expand Down

0 comments on commit fbff351

Please sign in to comment.