import sys from airflow import DAG from airflow.operators.python import PythonOperator from datetime import datetime def print_version(): print(f"Python Version: {sys.version}") with DAG("check_python_version", start_date=datetime(2024, 1, 1), schedule=None) as dag: task = PythonOperator(task_id="get_version", python_callable=print_version)