Merge pull request #785 from davidk01/patch-1

Fix issues with NoneType when shutting down
Parsely · Apr 19, 2018 · 6687224 · 6687224
2 parents 17a604b + f0f267f
commit 6687224
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/pykafka/handlers.py b/pykafka/handlers.py
@@ -186,9 +186,11 @@ def stop(self):
         """Stop the request processor."""
         shared = self.shared
         self.shared = None
-        log.info("RequestHandler.stop: about to flush requests queue")
-        shared.requests.join()
-        shared.ending.set()
+        if log:
+            log.info("RequestHandler.stop: about to flush requests queue")
+        if shared:
+            shared.requests.join()
+            shared.ending.set()
 
     def _start_thread(self):
         """Run the request processor"""