undo debug intentional crash
This commit is contained in:
parent
1a9ed19abc
commit
830a2ff76d
@ -81,9 +81,9 @@ class TestConsumer:
|
|||||||
queue_manager.clear()
|
queue_manager.clear()
|
||||||
storage.clear_bucket(bucket_name)
|
storage.clear_bucket(bucket_name)
|
||||||
|
|
||||||
# for data, message in items:
|
for data, message in items:
|
||||||
# storage.put_object(**get_object_descriptor(message), data=gzip.compress(data))
|
storage.put_object(**get_object_descriptor(message), data=gzip.compress(data))
|
||||||
# queue_manager.publish_request(message)
|
queue_manager.publish_request(message)
|
||||||
|
|
||||||
requests = consumer.consume(inactivity_timeout=5)
|
requests = consumer.consume(inactivity_timeout=5)
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user