Skip to content

Commit 36023e5

Browse files
committed
remove debug logging
1 parent 0c81b8f commit 36023e5

1 file changed

Lines changed: 0 additions & 2 deletions

File tree

tests/test_atomic_cursor.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -244,7 +244,6 @@ def consumer_process_worker(queue_name, cursor_name, worker_id, num_items, resul
244244
data, size, data_index = q.read(cursor)
245245
if data is not None:
246246
value = struct.unpack("<I", data[:4])[0]
247-
print(f"Process {worker_id} consumed an item {value} @ index {data_index}")
248247
consumed.append(value)
249248
time.sleep(random.uniform(0.0003, 0.0005))
250249
else:
@@ -269,7 +268,6 @@ def producer_worker(num_items: int, q: SlickQueue):
269268
data = struct.pack("<I", i)
270269
q[idx][:len(data)] = data
271270
q.publish(idx)
272-
print(f"Produced item {idx} {i}")
273271
time.sleep(random.uniform(0.001, 0.003)) # Slow producer
274272

275273
def test_atomic_cursor_shared_memory_mode():

0 commit comments

Comments
 (0)