We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ccda51f commit 97be9feCopy full SHA for 97be9fe
polytope_server/broker/broker.py
@@ -50,12 +50,8 @@ def run(self):
50
q = queue.create_queue(self.queue_config)
51
self.queue = q
52
try:
53
- try:
54
- while not time.sleep(self.scheduling_interval):
55
- self.check_requests()
56
- except KeyboardInterrupt:
57
- logging.info("Broker shutdown requested")
58
- raise
+ while not time.sleep(self.scheduling_interval):
+ self.check_requests()
59
finally:
60
q.close_connection()
61
self.request_store.close()
0 commit comments