From 8351a3abfa5814b4100c72fc201bac0c3571ee16 Mon Sep 17 00:00:00 2001
From: Zack Cerza <zack@cerza.org>
Date: Wed, 9 Oct 2013 13:11:15 -0500
Subject: [PATCH] PEP-8

Signed-off-by: Zack Cerza <zack.cerza@inktank.com>
---
 teuthology/queue.py | 25 +++++++++++++++----------
 1 file changed, 15 insertions(+), 10 deletions(-)

diff --git a/teuthology/queue.py b/teuthology/queue.py
index 2fae7d8b99..f0ebd08f3c 100644
--- a/teuthology/queue.py
+++ b/teuthology/queue.py
@@ -1,4 +1,3 @@
-import argparse
 import fcntl
 import logging
 import os
@@ -17,7 +16,10 @@ from . import safepath
 log = logging.getLogger(__name__)
 
 # simple flock class
+
+
 class filelock(object):
+
     def __init__(self, fn):
         self.fn = fn
         self.fd = None
@@ -49,7 +51,8 @@ def fetch_teuthology_branch(path, branch='master'):
     try:
         if not os.path.isdir(path):
             log.info("Cloning %s from upstream", branch)
-            teuthology_git_upstream = teuth_config.ceph_git_base_url + 'teuthology.git'
+            teuthology_git_upstream = teuth_config.ceph_git_base_url + \
+                'teuthology.git'
             log.info(
                 subprocess.check_output(('git', 'clone', '--branch', branch,
                                          teuthology_git_upstream, path),
@@ -93,6 +96,7 @@ def fetch_teuthology_branch(path, branch='master'):
     finally:
         lock.release()
 
+
 def worker(ctx):
     loglevel = logging.INFO
     if ctx.verbose:
@@ -101,18 +105,18 @@ def worker(ctx):
     logging.basicConfig(
         level=loglevel,
         filename=os.path.join(ctx.log_dir, 'worker.{tube}.{pid}'.format(
-                pid=os.getpid(),
-                tube=ctx.tube,
-                )),
+                              pid=os.getpid(),
+                              tube=ctx.tube,
+                              )),
         format='%(asctime)s.%(msecs)03d %(levelname)s:%(name)s:%(message)s',
         datefmt='%Y-%m-%dT%H:%M:%S',
-        )
+    )
 
     if not os.path.isdir(ctx.archive_dir):
         sys.exit("{prog}: archive directory must exist: {path}".format(
-                prog=os.path.basename(sys.argv[0]),
-                path=ctx.archive_dir,
-                ))
+            prog=os.path.basename(sys.argv[0]),
+            path=ctx.archive_dir,
+        ))
 
     from teuthology.misc import read_config
     read_config(ctx)
@@ -134,7 +138,8 @@ def worker(ctx):
 
         job_config['job_id'] = str(job.jid)
         safe_archive = safepath.munge(job_config['name'])
-        archive_path_full = os.path.join(ctx.archive_dir, safe_archive, str(job.jid))
+        archive_path_full = os.path.join(
+            ctx.archive_dir, safe_archive, str(job.jid))
         job_config['archive_path'] = archive_path_full
 
         # If the teuthology branch was not specified, default to master and
-- 
2.39.5