From 7c3e9e2e12fd3762e9a19498c4f6d383930f44db Mon Sep 17 00:00:00 2001 From: "pre-commit-ci[bot]" <66853113+pre-commit-ci[bot]@users.noreply.github.com> Date: Mon, 23 Sep 2024 21:43:24 +0000 Subject: [PATCH] [pre-commit.ci] auto fixes from pre-commit.com hooks for more information, see https://pre-commit.ci --- examples/admin.py | 1 + examples/consumer.py | 1 + examples/producer.py | 1 + src/asphalt/kafka/_admin.py | 1 + src/asphalt/kafka/_consumer.py | 1 + src/asphalt/kafka/_producer.py | 1 + tests/test_admin_client.py | 2 +- tests/test_consumer.py | 2 +- tests/test_producer.py | 2 +- 9 files changed, 9 insertions(+), 3 deletions(-) diff --git a/examples/admin.py b/examples/admin.py index 64ad3c2..f3f4ea8 100644 --- a/examples/admin.py +++ b/examples/admin.py @@ -1,4 +1,5 @@ from aiokafka.admin import AIOKafkaAdminClient, NewTopic + from asphalt.core import get_resource diff --git a/examples/consumer.py b/examples/consumer.py index 54397d8..06af3ba 100644 --- a/examples/consumer.py +++ b/examples/consumer.py @@ -1,4 +1,5 @@ from aiokafka import AIOKafkaConsumer + from asphalt.core import get_resource diff --git a/examples/producer.py b/examples/producer.py index ae6ddcd..1b07889 100644 --- a/examples/producer.py +++ b/examples/producer.py @@ -1,4 +1,5 @@ from aiokafka import AIOKafkaProducer + from asphalt.core import get_resource diff --git a/src/asphalt/kafka/_admin.py b/src/asphalt/kafka/_admin.py index 8a2445e..da9d9bf 100644 --- a/src/asphalt/kafka/_admin.py +++ b/src/asphalt/kafka/_admin.py @@ -6,6 +6,7 @@ from typing import Any from aiokafka.admin import AIOKafkaAdminClient + from asphalt.core import Component, add_resource, get_resource diff --git a/src/asphalt/kafka/_consumer.py b/src/asphalt/kafka/_consumer.py index 1235f0c..75fdccf 100644 --- a/src/asphalt/kafka/_consumer.py +++ b/src/asphalt/kafka/_consumer.py @@ -8,6 +8,7 @@ from typing import Any from aiokafka import AIOKafkaConsumer + from asphalt.core import Component, add_resource, context_teardown, get_resource diff --git a/src/asphalt/kafka/_producer.py b/src/asphalt/kafka/_producer.py index e8186ce..9d67fb9 100644 --- a/src/asphalt/kafka/_producer.py +++ b/src/asphalt/kafka/_producer.py @@ -6,6 +6,7 @@ from typing import Any from aiokafka import AIOKafkaProducer + from asphalt.core import Component, add_resource, get_resource diff --git a/tests/test_admin_client.py b/tests/test_admin_client.py index f59e059..14788a7 100644 --- a/tests/test_admin_client.py +++ b/tests/test_admin_client.py @@ -4,8 +4,8 @@ import pytest from aiokafka.admin import AIOKafkaAdminClient -from asphalt.core import Context, add_resource, get_resource_nowait, start_component +from asphalt.core import Context, add_resource, get_resource_nowait, start_component from asphalt.kafka import KafkaAdminComponent pytestmark = pytest.mark.anyio diff --git a/tests/test_consumer.py b/tests/test_consumer.py index 29ed2e0..225bf21 100644 --- a/tests/test_consumer.py +++ b/tests/test_consumer.py @@ -4,8 +4,8 @@ import pytest from aiokafka import AIOKafkaConsumer -from asphalt.core import Context, add_resource, get_resource_nowait, start_component +from asphalt.core import Context, add_resource, get_resource_nowait, start_component from asphalt.kafka import KafkaConsumerComponent pytestmark = pytest.mark.anyio diff --git a/tests/test_producer.py b/tests/test_producer.py index 6769641..cba4229 100644 --- a/tests/test_producer.py +++ b/tests/test_producer.py @@ -4,8 +4,8 @@ import pytest from aiokafka import AIOKafkaProducer -from asphalt.core import Context, add_resource, get_resource_nowait, start_component +from asphalt.core import Context, add_resource, get_resource_nowait, start_component from asphalt.kafka import KafkaProducerComponent pytestmark = pytest.mark.anyio