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

pika tearndown adjusted

Browse Source
This commit is contained in:
Matthias Bisping 2022-03-24 10:12:15 +01:00
parent 0206be8666
commit e3812725ac
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
pyinfra/test/unit_tests/conftest.py
View File

@ -126,9 +126,14 @@ def queue_manager(queue_manager_name):
queue_manager = get_queue_manager(queue_manager_name) queue_manager = get_queue_manager(queue_manager_name)
yield queue_manager yield queue_manager
if queue_manager_name == "pika": if queue_manager_name == "pika":
# try:
queue_manager.connection.close()
# except (pika.exceptions.StreamLostError, ConnectionResetError):
# pass
try: try:
queue_manager.connection.close() queue_manager.channel.close()
except (pika.exceptions.StreamLostError, ConnectionResetError): except pika.exceptions.ChannelWrongStateError:
logger.debug("Channel was already closed when attempting to close explicitly.")
pass pass