diff --git a/haystack/management/commands/update_index.py b/haystack/management/commands/update_index.py index d31ef12ee..55087d26d 100755 --- a/haystack/management/commands/update_index.py +++ b/haystack/management/commands/update_index.py @@ -228,6 +228,7 @@ def handle_label(self, label, **options): if self.workers > 0: pool = multiprocessing.Pool(self.workers) pool.map(worker, ghetto_queue) + pool.terminate() if self.remove: if self.start_date or self.end_date or total <= 0: @@ -251,3 +252,4 @@ def handle_label(self, label, **options): if self.workers > 0: pool = multiprocessing.Pool(self.workers) pool.map(worker, ghetto_queue) + pool.terminate()