From 83d90664fb7ce84d22a4cfa4d46c3fbfa6d31352 Mon Sep 17 00:00:00 2001
From: Ilan Steemers <koed00@gmail.com>
Date: Sun, 5 Aug 2018 11:12:14 +0200
Subject: [PATCH] Frees resources on sync run - @abompard

---
 django_q/tasks.py | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/django_q/tasks.py b/django_q/tasks.py
index 4d1acf6..6675561 100644
--- a/django_q/tasks.py
+++ b/django_q/tasks.py
@@ -8,6 +8,7 @@ from django.db import IntegrityError
 from django.utils import timezone
 
 # local
+from django_q.cluster import worker, monitor
 from django_q.signing import SignedPackage
 from django_q.conf import Conf, logger
 from django_q.models import Schedule, Task
@@ -673,10 +674,6 @@ class AsyncTask(object):
 
 
 def _sync(pack):
-    # Python 2.6 is unable to handle this import on top of the file
-    # because it creates a circular dependency between tasks and cluster
-    from django_q.cluster import worker, monitor
-
     """Simulate a package travelling through the cluster."""
     task_queue = Queue()
     result_queue = Queue()
@@ -686,4 +683,8 @@ def _sync(pack):
     worker(task_queue, result_queue, Value('f', -1))
     result_queue.put('STOP')
     monitor(result_queue)
+    task_queue.close()
+    task_queue.join_thread()
+    result_queue.close()
+    result_queue.join_thread()
     return task['id']