Skip to content

Commit

Permalink
semaphore errors corrected
Browse files Browse the repository at this point in the history
  • Loading branch information
PratRanj07 committed May 8, 2024
1 parent 86ae277 commit 5afe007
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 1 deletion.
2 changes: 1 addition & 1 deletion src/confluent_kafka/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@
TopicCollection,
TopicPartitionInfo,
IsolationLevel,
DeleteRecordsResult )
DeleteRecordsResult)

from .cimpl import (Producer,
Consumer,
Expand Down
1 change: 1 addition & 0 deletions src/confluent_kafka/_model/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -150,6 +150,7 @@ def __lt__(self, other):
return NotImplemented
return self.value < other.value


class DeleteRecordsResult:
"""
DeleteRecordsResult
Expand Down

0 comments on commit 5afe007

Please sign in to comment.