pep8: fix F401, F841

coriolis/minion_pools/api.py

@@ -2,7 +2,6 @@
 # All Rights Reserved.
 
 from coriolis.minion_manager.rpc import client as rpc_client
-from coriolis import utils
 
 
 class API(object):

coriolis/regions/api.py

@@ -2,7 +2,6 @@
 # All Rights Reserved.
 
 from coriolis.conductor.rpc import client as rpc_client
-from coriolis import utils
 
 
 class API(object):

coriolis/scheduler/filters/trivial_filters.py

@@ -3,7 +3,6 @@
 
 from oslo_log import log as logging
 
-from coriolis import constants
 from coriolis.scheduler.filters import base
 
 

coriolis/scheduler/scheduler_utils.py

@@ -10,7 +10,6 @@
 from coriolis import exception
 from coriolis.replica_cron.rpc import client as rpc_cron_client
 from coriolis.scheduler.rpc import client as rpc_scheduler_client
-from coriolis import utils
 from coriolis.worker.rpc import client as rpc_worker_client
 
 

coriolis/services/api.py

@@ -2,7 +2,6 @@
 # All Rights Reserved.
 
 from coriolis.conductor.rpc import client as rpc_client
-from coriolis import utils
 
 
 class API(object):

coriolis/taskflow/base.py

@@ -215,7 +215,7 @@ def _execute_task(
                 "successfully run and returned the following info: %s" % (
                     self._task_name, task_id, task_type, res))
             return res
-        except Exception as ex:
+        except Exception:
             LOG.debug(
                 "[Task %s] Exception occurred while executing task '%s' "
                 "(type '%s') on the worker service: %s", self._task_name,
@@ -242,7 +242,7 @@ def revert(self, context, origin, destination, task_info, **kwargs):
             res = self._execute_task(
                 context, self._task_id, self._cleanup_task_runner_type,
                 origin, destination, task_info)
-        except Exception as ex:
+        except Exception:
             LOG.warn(
                 "Task cleanup for '%s' (main task type '%s', cleanup task type"
                 "'%s') has failed with the following trace: %s",

coriolis/taskflow/runner.py

@@ -76,7 +76,7 @@ def _run_flow(self, flow, store=None):
         LOG.debug("Running flow with name '%s'", flow.name)
         try:
             engine.run()
-        except Exception as ex:
+        except Exception:
             LOG.warn(
                 "Fatal error occurred while attempting to run flow '%s'. "
                 "Full trace was: %s", flow.name,