attempt to fix dags for airflow 3

Author: maltesander

demos/argo-cd/dags/date_demo.py

@@ -6,7 +6,7 @@
 
 with DAG(
     dag_id='date_demo',
-    schedule_interval='0-59 * * * *',
+    schedule='0-59 * * * *',
     start_date=datetime(2021, 1, 1),
     catchup=False,
     dagrun_timeout=timedelta(minutes=5),

demos/argo-cd/dags/pyspark_pi.py

@@ -132,7 +132,7 @@ def poke(self, context: Dict) -> bool:
 
 with DAG(
         dag_id='sparkapp_dag',
-        schedule_interval=None,
+        schedule=None,
         start_date=datetime(2022, 1, 1),
         catchup=False,
         dagrun_timeout=timedelta(minutes=60),
@@ -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'), '../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()