| 1234567891011121314151617181920212223242526 |
- from airflow import DAG
- from airflow.operators.python import PythonOperator
- from datetime import datetime
- import sys
- def print_sys_path():
- print("=== sys.path 内容如下 ===")
- for path in sys.path:
- print(path)
- default_args = {
- 'start_date': datetime(2025, 1, 1),
- }
- with DAG(
- dag_id='check_sys_path_dag',
- default_args=default_args,
- schedule_interval=None,
- catchup=False,
- tags=['debug'],
- ) as dag:
- task_print_path = PythonOperator(
- task_id='print_sys_path',
- python_callable=print_sys_path
- )
|
