Skip to content

Commit 8362163

Browse files
committed
Resolved linting fixes
1 parent ffbaecd commit 8362163

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

tests/test_Producer.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -291,6 +291,7 @@ def test_producer_bool_value():
291291
assert bool(p)
292292
assert p.close(), "The producer was not fully closed"
293293

294+
294295
def test_produce_batch_basic_types_and_data():
295296
"""Test basic data types, None/empty handling, and partition functionality."""
296297
producer = Producer({'bootstrap.servers': 'localhost:9092'})
@@ -1415,8 +1416,10 @@ def test_producer_close():
14151416
}
14161417
producer = Producer(conf)
14171418
cb_detector = {"on_delivery_called": False}
1419+
14181420
def on_delivery(err, msg):
14191421
cb_detector["on_delivery_called"] = True
1422+
14201423
producer.produce('mytopic', value='somedata', key='a key', callback=on_delivery)
14211424
assert producer.close(), "The producer could not be closed on demand"
14221425
assert cb_detector["on_delivery_called"], "The delivery callback should have been called by flushing during close"

0 commit comments

Comments
 (0)