diff --git a/examples/stream_calc/sc_tests/integration/test_event_api.py b/examples/stream_calc/sc_tests/integration/test_event_api.py index 217b457c..34606ce1 100644 --- a/examples/stream_calc/sc_tests/integration/test_event_api.py +++ b/examples/stream_calc/sc_tests/integration/test_event_api.py @@ -33,7 +33,7 @@ from stream_calc.config import Config from stream_calc.main import main -DEFAULT_CONFIG = Config() +DEFAULT_CONFIG = Config() # type: ignore class Event(NamedTuple): @@ -207,7 +207,7 @@ async def test_receive_calc_publish(cases: list[Case] = deepcopy(CASES)): # run the stream_calc app: # (for each problem separately to avoid running forever) - config = Config(kafka_servers=[kafka_server]) + config = Config(kafka_servers=[kafka_server]) # type: ignore for _ in cases: await main(config=config, run_forever=False) diff --git a/examples/stream_calc/stream_calc/main.py b/examples/stream_calc/stream_calc/main.py index 73b8cf4e..3dbe1484 100644 --- a/examples/stream_calc/stream_calc/main.py +++ b/examples/stream_calc/stream_calc/main.py @@ -38,7 +38,9 @@ def get_container(config: Config) -> Container: return container -async def main(*, config: Config = Config(), run_forever: bool = True) -> None: +async def main( + *, config: Config = Config(), run_forever: bool = True # type: ignore +) -> None: """ Coroutine to run the stream calculator. diff --git a/tests/integration/test_akafka.py b/tests/integration/test_akafka.py index 5d245326..aa1049c8 100644 --- a/tests/integration/test_akafka.py +++ b/tests/integration/test_akafka.py @@ -41,7 +41,7 @@ async def test_kafka_event_publisher(kafka_fixture: KafkaFixture): # noqa: F811 key = "test_key" topic = "test_topic" - config = KafkaConfig( + config = KafkaConfig( # type: ignore service_name="test_publisher", service_instance_id="1", kafka_servers=kafka_fixture.kafka_servers, @@ -79,7 +79,7 @@ async def test_kafka_event_subscriber(kafka_fixture: KafkaFixture): # noqa: F81 ) # setup the provider: - config = KafkaConfig( + config = KafkaConfig( # type: ignore service_name="event_subscriber", service_instance_id="1", kafka_servers=kafka_fixture.kafka_servers, diff --git a/tests/integration/test_akafka_testutils.py b/tests/integration/test_akafka_testutils.py index b504205d..9e54c16a 100644 --- a/tests/integration/test_akafka_testutils.py +++ b/tests/integration/test_akafka_testutils.py @@ -100,7 +100,7 @@ async def test_event_recorder( """Test event recording using the EventRecorder class.""" topic = "test_topic" - config = KafkaConfig( + config = KafkaConfig( # type: ignore service_name="test_publisher", service_instance_id="1", kafka_servers=kafka_fixture.kafka_servers, @@ -142,7 +142,7 @@ async def test_expect_events_happy( ] topic = "test_topic" - config = KafkaConfig( + config = KafkaConfig( # type: ignore service_name="test_publisher", service_instance_id="1", kafka_servers=kafka_fixture.kafka_servers, @@ -240,7 +240,7 @@ async def test_expect_events_mismatch( ] topic = "test_topic" - config = KafkaConfig( + config = KafkaConfig( # type: ignore service_name="test_publisher", service_instance_id="1", kafka_servers=kafka_fixture.kafka_servers, diff --git a/tests/unit/test_akafka.py b/tests/unit/test_akafka.py index 354cdff5..98ce958f 100644 --- a/tests/unit/test_akafka.py +++ b/tests/unit/test_akafka.py @@ -45,7 +45,7 @@ async def test_kafka_event_publisher(): producer_class = Mock(return_value=producer) # publish event using the provider: - config = KafkaConfig( + config = KafkaConfig( # type: ignore service_name="test_publisher", service_instance_id="1", kafka_servers=["my-fake-kafka-server"], @@ -156,7 +156,7 @@ async def test_kafka_event_subscriber( translator.types_of_interest = types_of_interest # setup the provider: - config = KafkaConfig( + config = KafkaConfig( # type: ignore service_name=service_name, service_instance_id="1", kafka_servers=["my-fake-kafka-server"],