From 9c37e0649a75d22d5712b08dcd6c3acee412f719 Mon Sep 17 00:00:00 2001 From: buck heroux Date: Fri, 13 May 2016 15:26:21 -0400 Subject: [PATCH] pep8ing --- python/pyspark/context.py | 2 +- python/pyspark/tests.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/python/pyspark/context.py b/python/pyspark/context.py index 4ec4646411c7b..acd6ca1d5e7a0 100644 --- 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 index a6ba9f5cf257a..8c8070ba75112 100644 --- 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: