Rename package

Author: chandr-andr

.github/workflows/test.yml

@@ -48,7 +48,7 @@ jobs:
       - name: Install deps
         run: poetry install
       - name: Run pytest check
-        run: poetry run pytest -vv -n auto --cov="taskiq_kafka" .
+        run: poetry run pytest -vv -n auto --cov="taskiq_aio_kafka" .
       - name: Generate report
         run: poetry run coverage xml
       - name: Upload coverage reports to Codecov with GitHub Action

.pre-commit-config.yaml

@@ -41,14 +41,14 @@ repos:
         language: system
         pass_filenames: false
         types: [python]
-        args: [--count, taskiq_kafka]
+        args: [--count, taskiq_aio_kafka]
 
       - id: mypy
         name: Validate types with MyPy
         entry: poetry run mypy
         language: system
         types: [python]
-        args: [taskiq_kafka]
+        args: [taskiq_aio_kafka]
 
       - id: yesqa
         name: Remove usless noqa

README.md

@@ -4,7 +4,7 @@ This lirary provides you with aiokafka broker for taskiq.
 
 Usage:
 ```python
-from taskiq_kafka import AioKafkaBroker
+from taskiq_aio_kafka import AioKafkaBroker
 
 broker = AioKafkaBroker(bootstrap_servers="localhost")
 

pyproject.toml

@@ -21,7 +21,7 @@ classifiers = [
     "Development Status :: 3 - Alpha",
 ]
 keywords = ["taskiq", "tasks", "distributed", "async", "kafka", "aiokafka"]
-packages = [{ include = "taskiq_kafka" }]
+packages = [{ include = "taskiq_aio_kafka" }]
 
 [tool.poetry.dependencies]
 python = "^3.7"

taskiq_kafka/__init__.py taskiq_aio_kafka/__init__.pytaskiq_kafka/__init__.py renamed to taskiq_aio_kafka/__init__.py

@@ -1,4 +1,4 @@
 """Taskiq integration with aiokafka."""
-from taskiq_kafka.broker import AioKafkaBroker
+from taskiq_aio_kafka.broker import AioKafkaBroker
 
 __all__ = ["AioKafkaBroker"]

taskiq_kafka/broker.py taskiq_aio_kafka/broker.pytaskiq_kafka/broker.py renamed to taskiq_aio_kafka/broker.py

@@ -8,7 +8,7 @@
 from taskiq import AsyncResultBackend, BrokerMessage
 from taskiq.abc.broker import AsyncBroker
 
-from taskiq_kafka.exceptions import WrongAioKafkaBrokerParametersError
+from taskiq_aio_kafka.exceptions import WrongAioKafkaBrokerParametersError
 
 _T = TypeVar("_T")  # noqa: WPS111
 

taskiq_kafka/exceptions.py taskiq_aio_kafka/exceptions.pytaskiq_kafka/exceptions.py renamed to taskiq_aio_kafka/exceptions.py

@@ -6,7 +6,7 @@
 from aiokafka import AIOKafkaConsumer, AIOKafkaProducer
 from kafka.admin import NewTopic
 
-from taskiq_kafka.broker import AioKafkaBroker
+from taskiq_aio_kafka.broker import AioKafkaBroker
 
 
 @pytest.fixture(scope="session")

tests/conftest.py

@@ -7,7 +7,7 @@
 from aiokafka import AIOKafkaProducer
 from taskiq import BrokerMessage
 
-from taskiq_kafka.broker import AioKafkaBroker
+from taskiq_aio_kafka.broker import AioKafkaBroker
 
 
 async def get_first_task(broker: AioKafkaBroker) -> BrokerMessage:  # type: ignore