Skip to content

Commit

Permalink
Fixing services inject definitions
Browse files Browse the repository at this point in the history
  • Loading branch information
akadlec committed Jan 10, 2022
1 parent c8798cb commit ba3e440
Show file tree
Hide file tree
Showing 4 changed files with 2 additions and 8 deletions.
2 changes: 1 addition & 1 deletion redisdb_exchange_plugin/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -18,4 +18,4 @@
Redis DB exchange plugin
"""

__version__ = "0.5.0"
__version__ = "0.5.1"
2 changes: 1 addition & 1 deletion redisdb_exchange_plugin/exchange.py
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,7 @@ def __init__(
self,
redis_client: RedisClient,
logger: Logger,
consumer: Optional[IConsumer] = None,
consumer: IConsumer = None, # type: ignore[assignment]
) -> None:
super().__init__(name="Redis DB exchange client thread", daemon=True)

Expand Down
4 changes: 0 additions & 4 deletions redisdb_exchange_plugin/logger.py
Original file line number Diff line number Diff line change
Expand Up @@ -21,11 +21,7 @@
# Python base dependencies
import logging

# Library dependencies
from kink import inject


@inject
class Logger:
"""
Redis DB exchange plugin logger
Expand Down
2 changes: 0 additions & 2 deletions redisdb_exchange_plugin/publisher.py
Original file line number Diff line number Diff line change
Expand Up @@ -22,15 +22,13 @@
from typing import Dict, Optional

# Library dependencies
from kink import inject
from metadata.routing import RoutingKey
from metadata.types import ModuleOrigin

# Library libs
from redisdb_exchange_plugin.connection import RedisClient


@inject
class Publisher: # pylint: disable=too-few-public-methods
"""
Exchange data publisher
Expand Down

0 comments on commit ba3e440

Please sign in to comment.