From 3fbe85ef08fe764638bf4944e2fb30d2507140bb Mon Sep 17 00:00:00 2001 From: Jay-523 Date: Tue, 7 Jan 2025 21:28:11 +0530 Subject: [PATCH] testing demo changes for SA --- demo_spark_run/demo_spark_run.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/demo_spark_run/demo_spark_run.py b/demo_spark_run/demo_spark_run.py index 6ec5f93..1fbf34c 100644 --- a/demo_spark_run/demo_spark_run.py +++ b/demo_spark_run/demo_spark_run.py @@ -29,7 +29,7 @@ def upload_pyspark_file(**kwargs): staging_bucket = kwargs['ti'].xcom_pull(task_ids='get_cluster_config') with open(os.path.join(os.path.dirname(__file__), 'demo_pyspark_script.py'), 'r') as file: - pyspark_code = file.read() + pyspark_code = file.read() # adding a change # Upload the script to the staging bucket storage_client = storage.Client() bucket = storage_client.bucket(staging_bucket)