From 5afe007184b8aacbf4635bcb1ddb895384a93fb1 Mon Sep 17 00:00:00 2001 From: PratRanj07 Date: Thu, 2 May 2024 04:12:40 +0530 Subject: [PATCH] semaphore errors corrected --- src/confluent_kafka/__init__.py | 2 +- src/confluent_kafka/_model/__init__.py | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/src/confluent_kafka/__init__.py b/src/confluent_kafka/__init__.py index 7b9883bb9..7ba4a59cb 100644 --- a/src/confluent_kafka/__init__.py +++ b/src/confluent_kafka/__init__.py @@ -25,7 +25,7 @@ TopicCollection, TopicPartitionInfo, IsolationLevel, - DeleteRecordsResult ) + DeleteRecordsResult) from .cimpl import (Producer, Consumer, diff --git a/src/confluent_kafka/_model/__init__.py b/src/confluent_kafka/_model/__init__.py index 8b9983242..3b9c7d8a7 100644 --- a/src/confluent_kafka/_model/__init__.py +++ b/src/confluent_kafka/_model/__init__.py @@ -150,6 +150,7 @@ def __lt__(self, other): return NotImplemented return self.value < other.value + class DeleteRecordsResult: """ DeleteRecordsResult