pep8ing

apache · May 13, 2016 · 9c37e06 · 9c37e06
1 parent f4af842
commit 9c37e06
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/python/pyspark/context.py b/python/pyspark/context.py
@@ -834,7 +834,7 @@ def addPyPackage(self, pkg):
 
         import pyspark
         import foolib
-        
+
         sc = pyspark.SparkContext()
         sc.addPyPackage(foolib)
         # foolib now in workers PYTHONPATH

diff --git a/python/pyspark/tests.py b/python/pyspark/tests.py
@@ -1955,8 +1955,8 @@ def test_add_py_package(self):
                 temp.write("triple = lambda x: 3*x")
             pkg = __import__(name)
             with SparkContext() as sc:
-                #trips = sc.parallelize([0, 1, 2, 3]).map(pkg.triple)
-                #sc.addPyPackage(pkg)
+                # trips = sc.parallelize([0, 1, 2, 3]).map(pkg.triple)
+                # sc.addPyPackage(pkg)
                 trips = sc.parallelize([0, 1, 2, 3]).map(lambda x: pkg.triple(x))
                 self.assertSequenceEqual([0, 3, 6, 9], trips.collect())
         finally: