PEP8ify.

rq/queue.py

@@ -166,8 +166,8 @@ class Queue(object):
 
         # TODO: job with dependency shouldn't have "queued" as status
         job = self.job_class.create(func, args, kwargs, connection=self.connection,
-                         result_ttl=result_ttl, status=Status.QUEUED,
+                                    result_ttl=result_ttl, status=Status.QUEUED,
-                         description=description, depends_on=depends_on, timeout=timeout)
+                                    description=description, depends_on=depends_on, timeout=timeout)
 
         # If job depends on an unfinished job, register itself on it's
         # parent's dependents instead of enqueueing it.

rq/timeouts.py

@@ -1,4 +1,4 @@
- # -*- coding: utf-8 -*-
+# -*- coding: utf-8 -*-
 from __future__ import (absolute_import, division, print_function,
                         unicode_literals)
 

rq/utils.py

@@ -20,7 +20,9 @@ from .compat import is_python_version
 def gettermsize():
     def ioctl_GWINSZ(fd):
         try:
-            import fcntl, termios, struct  # noqa
+            import fcntl
+            import struct
+            import termios
             cr = struct.unpack('hh', fcntl.ioctl(fd, termios.TIOCGWINSZ, '1234'))
         except:
             return None

rq/worker.py

@@ -382,7 +382,7 @@ class Worker(object):
 
             try:
                 result = self.queue_class.dequeue_any(self.queues, timeout,
-                                           connection=self.connection)
+                                                      connection=self.connection)
                 if result is not None:
                     job, queue = result
                     self.log.info('%s: %s (%s)' % (green(queue.name),