Marmelator/pyinfra
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 36 Wiki Activity

debug intentional crash

Browse Source
This commit is contained in:
Matthias Bisping 2022-03-23 17:05:38 +01:00
parent c67c893dd3
commit 1a9ed19abc
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pyinfra/test/unit_tests/consumer_test.py
View File

@ -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)