Explicitly join() the scheduler.

coleifer · Oct 8, 2021 · 279ca4a · 279ca4a
1 parent b04bcb0
commit 279ca4a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/huey/consumer.py b/huey/consumer.py
@@ -406,6 +406,7 @@ def stop(self, graceful=False):
             try:
                 for _, worker_process in self.worker_threads:
                     worker_process.join()
+                self.scheduler.join()
             except KeyboardInterrupt:
                 self._logger.info('Received request to shut down now.')
             else: