From 0a2aed38d28c570ddcbbcee3803ce928794f554c Mon Sep 17 00:00:00 2001 From: Eagllus Date: Tue, 6 Feb 2018 11:17:09 +0100 Subject: [PATCH] Fix Python3 only code. Thanks to @P-EB for providing the solution --- django_q/queues.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/django_q/queues.py b/django_q/queues.py index ad729a1..20f082f 100644 --- a/django_q/queues.py +++ b/django_q/queues.py @@ -1,6 +1,7 @@ """ The code is derived from https://github.com/althonos/pronto/commit/3384010dfb4fc7c66a219f59276adef3288a886b """ +import sys import multiprocessing import multiprocessing.queues @@ -48,7 +49,11 @@ class Queue(multiprocessing.queues.Queue): """ def __init__(self, *args, **kwargs): - super(Queue, self).__init__(*args, ctx=multiprocessing.get_context(), **kwargs) + if sys.version_info < (3, 0): + super(Queue, self).__init__(*args, **kwargs) + else: + super(Queue, self).__init__(*args, ctx=multiprocessing.get_context(), **kwargs) + self.size = SharedCounter(0) def put(self, *args, **kwargs):