search

galaxyproject / pulsar

Distributed job execution application built for Galaxy
https://pulsar.readthedocs.io
Apache License 2.0
37 stars 50 forks source link

Catch drain timeout without verbose log message #325

Closed mvdbeek closed 1 year ago

mvdbeek commented 1 year ago

Avoids verbose log messages like

2023-04-28 16:07:36,784 WARNI [pulsar.client.amqp_exchange][consume-setup-amqp://guest:********@localhost:5672] Got TimeoutError, will retry: timed out
2023-04-28 16:07:36,784 WARNI [pulsar.client.amqp_exchange][consume-status-amqp://guest:********@localhost:5672] Got TimeoutError, will retry: timed out
2023-04-28 16:07:36,784 WARNI [pulsar.client.amqp_exchange][consume-kill-amqp://guest:********@localhost:5672] Got TimeoutError, will retry: timed out
2023-04-28 16:07:37,578 DEBUG [pulsar.client.amqp_exchange][consume-heartbeat-pulsar__status] AMQP heartbeat thread exiting
2023-04-28 16:07:37,579 DEBUG [pulsar.client.amqp_exchange][consume-heartbeat-pulsar__kill] AMQP heartbeat thread exiting
2023-04-28 16:07:37,579 DEBUG [pulsar.client.amqp_exchange][consume-heartbeat-pulsar__setup] AMQP heartbeat thread exiting
2023-04-28 16:07:38,600 DEBUG [pulsar.client.amqp_exchange][consume-heartbeat-pulsar__status] AMQP heartbeat thread alive
2023-04-28 16:07:38,602 DEBUG [pulsar.client.amqp_exchange][consume-heartbeat-pulsar__kill] AMQP heartbeat thread alive
2023-04-28 16:07:38,603 DEBUG [pulsar.client.amqp_exchange][consume-heartbeat-pulsar__setup] AMQP heartbeat thread alive