fork/django-q2
1
0
Fork 0
mirror of https://github.com/django-q2/django-q2.git synced 2026-10-02 09:48:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #356 from lamby/import-error-issue-331

Browse Source 
Inline import to prevent circular imports under some toolchain combinations
This commit is contained in:
Ilan Steemers
2019-08-10 14:14:30 +02:00
committed by GitHub
parent a72b8171ec 5c8243903f
commit cfeceb497d
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/tasks.py
+1 -1
View File
@@ -9,7 +9,6 @@ from multiprocessing import Value
from django_q.brokers import get_broker from django_q.brokers import get_broker
# local # local
from django_q.cluster import worker, monitor
from django_q.conf import Conf, logger from django_q.conf import Conf, logger
from django_q.humanhash import uuid from django_q.humanhash import uuid
from django_q.models import Schedule, Task from django_q.models import Schedule, Task
@@ -676,6 +675,7 @@ class AsyncTask(object):
def _sync(pack): def _sync(pack):
"""Simulate a package travelling through the cluster.""" """Simulate a package travelling through the cluster."""
from django_q.cluster import worker, monitor
task_queue = Queue() task_queue = Queue()
result_queue = Queue() result_queue = Queue()
task = SignedPackage.loads(pack) task = SignedPackage.loads(pack)