pep8 fixes

holdenk · holdenk · commit 15d999bb901a · 2017-03-14T16:42:20.000-07:00
diff --git a/python/pyspark/java_gateway.py b/python/pyspark/java_gateway.py
@@ -27,7 +27,7 @@
 import socket
 import platform
 from subprocess import Popen, PIPE
-from threading  import Thread
+from threading import Thread
 
 
 if sys.version >= '3':
diff --git a/python/run-tests.py b/python/run-tests.py
@@ -113,19 +113,21 @@ def run_generic_test(test_name, pyspark_python, launch_cmd):
         per_test_output.close()
         LOGGER.info("Finished test(%s): %s (%is)", pyspark_python, test_name, duration)
 
+
 def run_standalone_python_test(test_name, pyspark_python):
     """
     Runs a standalone python test. This verifies PySpark launch behaviour when starting the JVM from
     Python side instead of JVM starting Python.
     """
-    launch_cmd=pyspark_python
-    run_generic_test(test_name, pyspark_python, launch_cmd)
+    run_generic_test(test_name, pyspark_python, launch_cmd=pyspark_python)
+
 
 def run_individual_python_test(test_name, pyspark_python):
     """Run a Python test launching the JVM first."""
     launch_cmd = os.path.join(SPARK_HOME, "bin/pyspark")
     run_generic_test(test_name, pyspark_python, launch_cmd)
 
+
 def get_default_python_executables():
     python_execs = [x for x in ["python2.6", "python3.4", "pypy"] if which(x)]
     if "python2.6" not in python_execs:
