change path in correct airflow file...

Author: maltesander

demos/argo-cd/dags/pyspark_pi.py

@@ -147,7 +147,7 @@ def load_body_to_dict(body):
             raise AirflowException(f"Exception when loading resource definition: {e}\n")
         return body_dict
 
-    yaml_path = os.path.join(os.environ.get('AIRFLOW__CORE__DAGS_FOLDER'), 'pyspark_pi.yaml')
+    yaml_path = os.path.join(os.environ.get('AIRFLOW__CORE__DAGS_FOLDER'), '../manifests/spark-k8s/pyspark_pi.yaml')
 
     with open(yaml_path, 'r') as file:
         crd = file.read()

stacks/airflow/airflow.yaml

@@ -238,7 +238,7 @@ data:
                 raise AirflowException(f"Exception when loading resource definition: {e}\n")
             return body_dict
 
-        yaml_path = os.path.join(os.environ.get('AIRFLOW__CORE__DAGS_FOLDER'), '../manifests/spark-k8s/pyspark_pi.yaml')
+        yaml_path = os.path.join(os.environ.get('AIRFLOW__CORE__DAGS_FOLDER'), 'pyspark_pi.yaml')
 
         with open(yaml_path, 'r') as file:
             crd = file.read()