mirror of
https://github.com/django-q2/django-q2.git
synced 2026-10-09 08:08:11 +08:00
removes xrange compat
This commit is contained in:
@@ -23,7 +23,6 @@ from multiprocessing import Event, Process, Value, current_process
|
|||||||
# Local
|
# Local
|
||||||
from django_q import tasks
|
from django_q import tasks
|
||||||
from django_q.brokers import get_broker
|
from django_q.brokers import get_broker
|
||||||
from django_q.compat import range
|
|
||||||
from django_q.conf import Conf, logger, psutil, get_ppid, error_reporter, rollbar
|
from django_q.conf import Conf, logger, psutil, get_ppid, error_reporter, rollbar
|
||||||
from django_q.models import Task, Success, Schedule
|
from django_q.models import Task, Success, Schedule
|
||||||
from django_q.queues import Queue
|
from django_q.queues import Queue
|
||||||
|
|||||||
@@ -1,14 +0,0 @@
|
|||||||
from __future__ import absolute_import
|
|
||||||
"""
|
|
||||||
Compatibility layer.
|
|
||||||
|
|
||||||
Intentionally replaces use of python-future
|
|
||||||
"""
|
|
||||||
|
|
||||||
# https://github.com/Koed00/django-q/issues/4
|
|
||||||
|
|
||||||
try:
|
|
||||||
range = xrange
|
|
||||||
except NameError:
|
|
||||||
range = range
|
|
||||||
|
|
||||||
@@ -5,7 +5,6 @@ import pytest
|
|||||||
import redis
|
import redis
|
||||||
|
|
||||||
from django_q.brokers import get_broker, Broker
|
from django_q.brokers import get_broker, Broker
|
||||||
from django_q.compat import range
|
|
||||||
from django_q.conf import Conf
|
from django_q.conf import Conf
|
||||||
from django_q.humanhash import uuid
|
from django_q.humanhash import uuid
|
||||||
|
|
||||||
|
|||||||
@@ -3,7 +3,6 @@ from multiprocessing import Event, Value
|
|||||||
import pytest
|
import pytest
|
||||||
|
|
||||||
from django_q.cluster import pusher, worker, monitor
|
from django_q.cluster import pusher, worker, monitor
|
||||||
from django_q.compat import range
|
|
||||||
from django_q.conf import Conf
|
from django_q.conf import Conf
|
||||||
from django_q.tasks import async_task, result, fetch, count_group, result_group, fetch_group, delete_group, delete_cached, \
|
from django_q.tasks import async_task, result, fetch, count_group, result_group, fetch_group, delete_group, delete_cached, \
|
||||||
async_iter, Chain, async_chain, Iter, AsyncTask
|
async_iter, Chain, async_chain, Iter, AsyncTask
|
||||||
|
|||||||
@@ -11,7 +11,6 @@ myPath = os.path.dirname(os.path.abspath(__file__))
|
|||||||
sys.path.insert(0, myPath + '/../')
|
sys.path.insert(0, myPath + '/../')
|
||||||
|
|
||||||
from django_q.cluster import Cluster, Sentinel, pusher, worker, monitor, save_task
|
from django_q.cluster import Cluster, Sentinel, pusher, worker, monitor, save_task
|
||||||
from django_q.compat import range
|
|
||||||
from django_q.humanhash import DEFAULT_WORDLIST, uuid
|
from django_q.humanhash import DEFAULT_WORDLIST, uuid
|
||||||
from django_q.tasks import fetch, fetch_group, async_task, result, result_group, count_group, delete_group, queue_size
|
from django_q.tasks import fetch, fetch_group, async_task, result, result_group, count_group, delete_group, queue_size
|
||||||
from django_q.models import Task, Success
|
from django_q.models import Task, Success
|
||||||
|
|||||||
@@ -3,7 +3,6 @@ import pytest
|
|||||||
from django_q.tasks import async_task
|
from django_q.tasks import async_task
|
||||||
from django_q.brokers import get_broker
|
from django_q.brokers import get_broker
|
||||||
from django_q.cluster import Cluster
|
from django_q.cluster import Cluster
|
||||||
from django_q.compat import range
|
|
||||||
from django_q.monitor import monitor, info
|
from django_q.monitor import monitor, info
|
||||||
from django_q.status import Stat
|
from django_q.status import Stat
|
||||||
from django_q.conf import Conf
|
from django_q.conf import Conf
|
||||||
|
|||||||
Reference in New Issue
Block a user