From a8f5a3ceae67002804b847f20f89e4606edc2d07 Mon Sep 17 00:00:00 2001 From: Ben McKerry <110857332+bmckerry@users.noreply.github.com> Date: Mon, 8 Jun 2026 16:47:55 -0400 Subject: [PATCH] fix(producer): DummyProducer typing --- clients/python/tests/worker/test_producer.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clients/python/tests/worker/test_producer.py b/clients/python/tests/worker/test_producer.py index 43ab3be0..2efb42fb 100644 --- a/clients/python/tests/worker/test_producer.py +++ b/clients/python/tests/worker/test_producer.py @@ -26,7 +26,7 @@ def __init__(self, use_simple_futures: bool): self.use_simple_futures = use_simple_futures def produce( - self, topic: Topic, payload: KafkaPayload + self, destination: Topic | Partition, payload: KafkaPayload ) -> ProducerFuture[BrokerValue[KafkaPayload]]: future: ProducerFuture[BrokerValue[KafkaPayload]] if self.use_simple_futures: