From e5906286125418e4d9e0ca37b6e310cbdd27d9fd Mon Sep 17 00:00:00 2001 From: Ilan Steemers Date: Fri, 10 Jul 2015 12:14:57 +0200 Subject: [PATCH] linting some blank lines --- django_q/admin.py | 1 - django_q/apps.py | 1 + django_q/cluster.py | 5 ++--- django_q/conf.py | 2 ++ django_q/signing.py | 4 +++- django_q/tasks.py | 1 - 6 files changed, 8 insertions(+), 6 deletions(-) diff --git a/django_q/admin.py b/django_q/admin.py index b2e0647..7dacac5 100644 --- a/django_q/admin.py +++ b/django_q/admin.py @@ -1,5 +1,4 @@ from django.contrib import admin - from django.utils.translation import ugettext_lazy as _ from .tasks import async diff --git a/django_q/apps.py b/django_q/apps.py index 72705fd..54c09f1 100644 --- a/django_q/apps.py +++ b/django_q/apps.py @@ -1,4 +1,5 @@ from django.apps import AppConfig + from .conf import Conf diff --git a/django_q/cluster.py b/django_q/cluster.py index 696ec35..2a3ec1c 100644 --- a/django_q/cluster.py +++ b/django_q/cluster.py @@ -35,8 +35,6 @@ from django_q.models import Task, Success, Schedule from django_q.monitor import Status, Stat - - class Cluster(object): def __init__(self, list_key=Conf.Q_LIST): try: @@ -450,7 +448,8 @@ def scheduler(list_key=Conf.Q_LIST): kwargs['list_key'] = list_key s.task = tasks.async(s.func, *args, **kwargs) if not s.task: - logger.error(_('{} failed to create a task from schedule {} [{}]').format(current_process().name, s.id), s.func) + logger.error(_('{} failed to create a task from schedule {} [{}]').format(current_process().name, s.id), + s.func) else: logger.info(_('{} created a task from schedule {} [{}]').format(current_process().name, s.id, s.func)) s.save() diff --git a/django_q/conf.py b/django_q/conf.py index b195637..37e04bf 100644 --- a/django_q/conf.py +++ b/django_q/conf.py @@ -64,6 +64,7 @@ class Conf(object): STOPPED = _('Stopped') STOPPING = _('Stopping') + # logger logger = logging.getLogger('django-q') @@ -90,5 +91,6 @@ def get_redis_client(): return django_redis.get_redis_connection(Conf.DJANGO_REDIS) return redis.StrictRedis(**Conf.REDIS) + # redis client redis_client = get_redis_client() diff --git a/django_q/signing.py b/django_q/signing.py index 963cc7e..19e6341 100644 --- a/django_q/signing.py +++ b/django_q/signing.py @@ -4,10 +4,12 @@ except ImportError: import pickle from django.core import signing + from django_q.conf import Conf BadSignature = signing.BadSignature + class SignedPackage(object): """ Wraps Django's signing module with custom Pickle serializer @@ -41,4 +43,4 @@ class PickleSerializer(object): @staticmethod def loads(data): - return pickle.loads(data) \ No newline at end of file + return pickle.loads(data) diff --git a/django_q/tasks.py b/django_q/tasks.py index 200669b..9747fd1 100644 --- a/django_q/tasks.py +++ b/django_q/tasks.py @@ -107,4 +107,3 @@ def _sync(task_id, pack): result_queue.put('STOP') cluster.monitor(result_queue) return task_id -