diff --git a/airflow/example_dags/example_kubernetes_executor.py b/airflow/example_dags/example_kubernetes_executor.py index c5367c08076a4..af44685ad26f9 100644 --- a/airflow/example_dags/example_kubernetes_executor.py +++ b/airflow/example_dags/example_kubernetes_executor.py @@ -21,7 +21,7 @@ """ import os -from libs import print_stuff +from libs.helper import print_stuff from airflow.models import DAG from airflow.operators.python import PythonOperator diff --git a/airflow/example_dags/example_kubernetes_executor_config.py b/airflow/example_dags/example_kubernetes_executor_config.py index 9356e197feda5..ab84f9963862c 100644 --- a/airflow/example_dags/example_kubernetes_executor_config.py +++ b/airflow/example_dags/example_kubernetes_executor_config.py @@ -21,7 +21,7 @@ """ import os -from libs import print_stuff +from libs.helper import print_stuff from airflow.models import DAG from airflow.operators.python import PythonOperator diff --git a/scripts/ci/in_container/kubernetes/docker/airflow-test-env-init.sh b/scripts/ci/in_container/kubernetes/docker/airflow-test-env-init.sh index fc06f83403aaf..18a8ec5607c77 100755 --- a/scripts/ci/in_container/kubernetes/docker/airflow-test-env-init.sh +++ b/scripts/ci/in_container/kubernetes/docker/airflow-test-env-init.sh @@ -20,6 +20,7 @@ set -x cd /opt/airflow/airflow && \ cp -R example_dags/* /root/airflow/dags/ && \ +find /root/airflow/dags/ && \ airflow db init && \ alembic upgrade heads && \ (airflow users create --username airflow --lastname airflow --firstname jon --email airflow@apache.org --role Admin --password airflow || true) && \