Quote consistency

celery/bin/celery.py

@@ -407,8 +407,8 @@ class purge(Command):
     WARNING: There is no undo operation for this command.
 
     """
-    fmt_purged = "Purged {mnum} {messages} from {qnum} known task {queues}."
-    fmt_empty = "No messages purged from {qnum} {queues}"
+    fmt_purged = 'Purged {mnum} {messages} from {qnum} known task {queues}.'
+    fmt_empty = 'No messages purged from {qnum} {queues}'
 
     def run(self, *args, **kwargs):
         queues = len(self.app.amqp.queues.keys())

celery/contrib/rdb.py

@@ -70,8 +70,8 @@ Type `exit` in session to continue.
 {self.ident}: Waiting for client...
 """
 
-SESSION_STARTED = "{self.ident}: Now in session with {self.remote_addr}."
-SESSION_ENDED = "{self.ident}: Session with {self.remote_addr} ended."
+SESSION_STARTED = '{self.ident}: Now in session with {self.remote_addr}.'
+SESSION_ENDED = '{self.ident}: Session with {self.remote_addr} ended.'
 
 
 class Rdb(Pdb):

celery/result.py

@@ -432,7 +432,7 @@ class ResultSet(ResultBase):
             time.sleep(interval)
             elapsed += interval
             if timeout and elapsed >= timeout:
-                raise TimeoutError("The operation timed out")
+                raise TimeoutError('The operation timed out')
 
     def get(self, timeout=None, propagate=True, interval=0.5):
         """See :meth:`join`
@@ -679,7 +679,7 @@ class EagerResult(AsyncResult):
         self._state = states.REVOKED
 
     def __repr__(self):
-        return "<EagerResult: {0.id}>".format(self)
+        return '<EagerResult: {0.id}>'.format(self)
 
     @property
     def result(self):

celery/schedules.py

@@ -205,7 +205,7 @@ class crontab_parser(object):
             try:
                 i = weekday(s)
             except KeyError:
-                raise ValueError("Invalid weekday literal {0!r}.".format(s))
+                raise ValueError('Invalid weekday literal {0!r}.'.format(s))
 
         if i < self.min_:
             raise ValueError(

celery/task/http.py

@@ -134,7 +134,7 @@ class HttpDispatch(object):
         self.url = url
         self.method = method
         self.task_kwargs = task_kwargs
-        self.logger = kwargs.get("logger") or logger
+        self.logger = kwargs.get('logger') or logger
 
     def make_request(self, url, method, params):
         """Makes an HTTP request and returns the response."""

celery/utils/__init__.py

@@ -199,7 +199,7 @@ def strtobool(term, table={'false': False, 'no': False, '0': False,
 
 
 def jsonify(obj):
-    "Transforms object making it suitable for json serialization"
+    """Transforms object making it suitable for json serialization"""
     if isinstance(obj, (int, float, basestring, types.NoneType)):
         return obj
     elif isinstance(obj, (tuple, list)):
@@ -224,7 +224,7 @@ def jsonify(obj):
     elif isinstance(obj, datetime.timedelta):
         return str(obj)
     else:
-        raise ValueError("Unsupported type: {0}".format(type(obj)))
+        raise ValueError('Unsupported type: {0}'.format(type(obj)))
 
 
 def gen_task_name(app, name, module_name):

celery/utils/threads.py

@@ -15,7 +15,7 @@ import traceback
 
 from kombu.syn import detect_environment
 
-USE_PURE_LOCALS = os.environ.get("USE_PURE_LOCALS")
+USE_PURE_LOCALS = os.environ.get('USE_PURE_LOCALS')
 
 
 class bgThread(threading.Thread):

celery/worker/consumer.py

@@ -154,7 +154,7 @@ def debug(msg, *args, **kwargs):
 
 
 def dump_body(m, body):
-    return "{0} ({1}b)".format(text.truncate(safe_repr(body), 1024),
+    return '{0} ({1}b)'.format(text.truncate(safe_repr(body), 1024),
                                len(m.body))