diff --git a/.travis.yml b/.travis.yml index 269d24f..991ec23 100644 --- a/.travis.yml +++ b/.travis.yml @@ -5,6 +5,7 @@ services: - mongodb python: + - "2.7" - "3.6" env: @@ -12,6 +13,11 @@ env: - DJANGO=1.11.9 - DJANGO=1.8.18 +matrix: + exclude: + - python: "2.7" + env: DJANGO=2.0 + sudo: false addons: diff --git a/django_q/core_signing.py b/django_q/core_signing.py index 1790a0b..c433c83 100644 --- a/django_q/core_signing.py +++ b/django_q/core_signing.py @@ -62,7 +62,7 @@ class TimestampSigner(Signer, TsS): Retrieve original value and check it wasn't signed more than max_age seconds ago. """ - result = super().unsign(value) + result = super(TimestampSigner, self).unsign(value) value, timestamp = result.rsplit(self.sep, 1) timestamp = baseconv.base62.decode(timestamp) if max_age is not None: 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):