Fix pep8 issues
diff --git a/turbo_hipster/task_plugins/gate_real_db_upgrade/handle_results.py b/turbo_hipster/task_plugins/gate_real_db_upgrade/handle_results.py
index 445f3eb..b3e7961 100644
--- a/turbo_hipster/task_plugins/gate_real_db_upgrade/handle_results.py
+++ b/turbo_hipster/task_plugins/gate_real_db_upgrade/handle_results.py
@@ -111,12 +111,13 @@
# Check the final version is as expected
final_version = MIGRATION_FINAL_SCHEMA_RE.findall(line)[0]
if int(final_version) != max(schemas):
- return False, "Final schema version does not match expectation"
+ return False, ("Final schema version does not match "
+ "expectation")
if migration_started:
# We never saw the end of a migration,
# something must have failed
return False, ("FAILURE: Did not find the end of a migration "
- "after a start")
+ "after a start")
return True, "SUCCESS"
diff --git a/turbo_hipster/task_plugins/gate_real_db_upgrade/task.py b/turbo_hipster/task_plugins/gate_real_db_upgrade/task.py
index 68d9544..113bdea 100644
--- a/turbo_hipster/task_plugins/gate_real_db_upgrade/task.py
+++ b/turbo_hipster/task_plugins/gate_real_db_upgrade/task.py
@@ -306,7 +306,8 @@
self.log.debug("Grab the patchset we want to test against")
repo = utils.GitRepository(
- self.global_config['zuul_server']['git_url'] + project_name + '/.git',
+ self.global_config['zuul_server']['git_url'] +
+ project_name + '/.git',
os.path.join(
self.global_config['git_working_dir'],
__worker_name__,
diff --git a/turbo_hipster/worker_server.py b/turbo_hipster/worker_server.py
index f5404ae..9bf0124 100755
--- a/turbo_hipster/worker_server.py
+++ b/turbo_hipster/worker_server.py
@@ -21,7 +21,6 @@
import argparse
import daemon
import extras
-import imp
import json
import logging
import os
@@ -79,8 +78,10 @@
""" Run the tasks """
for plugin in self.plugins:
module = plugin['module']
- self.tasks[module.__worker_name__] = module.Runner(self.config,
- plugin['plugin_config'])
+ self.tasks[module.__worker_name__] = module.Runner(
+ self.config,
+ plugin['plugin_config']
+ )
self.tasks[module.__worker_name__].daemon = True
self.tasks[module.__worker_name__].start()