simple test DAG

2024-03-11 18:44:45 +01:00 · 2024-03-11 18:44:45 +01:00 · b4f8ba1bd0
parent dd07466aae
commit b4f8ba1bd0
1 changed files with 1 additions and 0 deletions
--- a/airflow/dags/spark_pi.py
+++ b/airflow/dags/spark_pi.py
@ -95,6 +95,7 @@ submit = SparkKubernetesOperator(
    namespace='lot1-spark-jobs',
    template_spec=spec,
    kubernetes_conn_id="kubernetes_default",
+    do_xcom_push=True,
 #    delete_on_termination=True,
    dag=dag
 )