File tree Expand file tree Collapse file tree 2 files changed +5
-3
lines changed Expand file tree Collapse file tree 2 files changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -1586,6 +1586,7 @@ def stop(self):
15861586 Note that if you don't call this before your application exits, there
15871587 may be some records still left on the queue, which won't be processed.
15881588 """
1589- self .enqueue_sentinel ()
1590- self ._thread .join ()
1591- self ._thread = None
1589+ if self ._thread : # see gh-114706 - allow calling this more than once
1590+ self .enqueue_sentinel ()
1591+ self ._thread .join ()
1592+ self ._thread = None
Original file line number Diff line number Diff line change @@ -4089,6 +4089,7 @@ def test_queue_listener(self):
40894089 self .que_logger .critical (self .next_message ())
40904090 finally :
40914091 listener .stop ()
4092+ listener .stop () # gh-114706 - ensure no crash if called again
40924093 self .assertTrue (handler .matches (levelno = logging .WARNING , message = '1' ))
40934094 self .assertTrue (handler .matches (levelno = logging .ERROR , message = '2' ))
40944095 self .assertTrue (handler .matches (levelno = logging .CRITICAL , message = '3' ))
You can’t perform that action at this time.
0 commit comments