testing demo changes for SA

yral-dapp · Jan 7, 2025 · 3fbe85e · 3fbe85e
1 parent 24e98a2
commit 3fbe85e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)