[test] Pre-commit cleanup

beat/core/test/test_bcp.py

@@ -43,6 +43,7 @@ import unittest
 
 import simplejson as json
 import zmq
+
 from flaky import flaky
 
 from ..bcp import broker

beat/core/test/test_docker.py

@@ -39,6 +39,7 @@ import os
 import tempfile
 import time
 import unittest
+
 from tempfile import TemporaryDirectory
 
 import pkg_resources

beat/core/test/test_docker_execution.py

@@ -306,7 +306,8 @@ class TestDockerExecution(BaseExecutionMixIn):
     def test_loop_mix_db_env_error(self):
         with nose.tools.assert_raises(RuntimeError) as context:
             self.execute(
-                "errors/user/loop/1/loop_mix_db_env", [None],
+                "errors/user/loop/1/loop_mix_db_env",
+                [None],
             )
 
         nose.tools.assert_true(
@@ -317,7 +318,8 @@ class TestDockerExecution(BaseExecutionMixIn):
     def test_loop_two_db_env_error(self):
         with nose.tools.assert_raises(RuntimeError) as context:
             self.execute(
-                "errors/user/loop/1/loop_two_db_environments", [None],
+                "errors/user/loop/1/loop_two_db_environments",
+                [None],
             )
 
         nose.tools.assert_true(
@@ -328,7 +330,8 @@ class TestDockerExecution(BaseExecutionMixIn):
     def test_single_not_existing_db_env_error(self):
         with nose.tools.assert_raises(RuntimeError) as context:
             self.execute(
-                "errors/user/single/1/not_existing_db_env", [None],
+                "errors/user/single/1/not_existing_db_env",
+                [None],
             )
 
         nose.tools.assert_true(

beat/core/test/test_execution.py

@@ -40,6 +40,7 @@ import glob
 import logging
 import os
 import subprocess as sp  # nosec
+
 from shutil import rmtree
 
 import nose.tools
@@ -95,8 +96,7 @@ def clear_conda_environment(environment_prefix):
 
 class BaseExecutionMixIn(object):
     def check_output(self, prefix, path):
-        """Checks if a given output exists, together with its indexes and checksums
-        """
+        """Checks if a given output exists, together with its indexes and checksums"""
 
         finalpath = os.path.join(prefix, path)
         datafiles = glob.glob(finalpath + "*.data")

beat/core/test/test_worker.py

@@ -40,10 +40,12 @@ import multiprocessing
 import os
 import queue
 import unittest
+
 from time import sleep
 from time import time
 
 import simplejson as json
+
 from ddt import ddt
 from ddt import idata