在dag之间使用单独的environ和sys.path

为了从其他路径引入特定模块，我在这里使用解决方案通过指定其他python模块的绝对文件路径来导入它们。

为了使用不同的python解释器将各种python脚本作为气流任务运行，我做了类似…

do_stuff_a = BashOperator(        task_id='my_task_a',        bash_command='/path/to/virtualenv_a/bin/python /path/to/script_a.py'),        execution_timeout=timedelta(minutes=30),        dag=dag)

就像这里的类似问题一样