Skip to content

Commit 6484fb0

Browse files
committed
format
1 parent 4dd472c commit 6484fb0

File tree

1 file changed

+2
-6
lines changed

1 file changed

+2
-6
lines changed

tests/integ/test_spark_processing.py

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -210,9 +210,7 @@ def test_sagemaker_pyspark_v3(
210210
spark_v3_py_processor, spark_v3_jar_processor, sagemaker_session, configuration
211211
):
212212
test_sagemaker_pyspark_multinode(spark_v3_py_processor, sagemaker_session, configuration)
213-
test_sagemaker_java_jar_multinode(
214-
spark_v3_jar_processor, sagemaker_session, configuration
215-
)
213+
test_sagemaker_java_jar_multinode(spark_v3_jar_processor, sagemaker_session, configuration)
216214

217215

218216
def test_sagemaker_pyspark_multinode(spark_py_processor, sagemaker_session, configuration):
@@ -280,9 +278,7 @@ def test_sagemaker_pyspark_multinode(spark_py_processor, sagemaker_session, conf
280278
assert len(output_contents) != 0
281279

282280

283-
def test_sagemaker_java_jar_multinode(
284-
spark_jar_processor, sagemaker_session, configuration
285-
):
281+
def test_sagemaker_java_jar_multinode(spark_jar_processor, sagemaker_session, configuration):
286282
"""Test SparkJarProcessor using Java application jar"""
287283
bucket = spark_jar_processor.sagemaker_session.default_bucket()
288284
with open(os.path.join(SPARK_PATH, "files", "data.jsonl")) as data:

0 commit comments

Comments
 (0)