如何使用EcsOperator Airflow在不同的文件夹中运行命令

pip install apache-airflow[aws]

from airflow import DAG
from airflow.operators import EcsOperator
from datetime import datetime

default_args = {
    'owner': 'your_name',
    'depends_on_past': False,
    'start_date': datetime(2022, 1, 1),
    'email': ['your_email@example.com'],
    'email_on_failure': False,
    'email_on_retry': False,
    'retries': 1,
    'retry_delay': timedelta(minutes=5),
}
dag = DAG(
    'ecs_operator_example',
    default_args=default_args,
    description='Example DAG using EcsOperator',
    schedule_interval=timedelta(days=1),
)

task_definition = 'your_task_definition'
cluster = 'your_cluster'
container = 'your_container'
command = ['your_command', 'arg1', 'arg2']

task = EcsOperator(
    task_id='ecs_task',
    task_definition=task_definition,
    cluster=cluster,
    overrides={
        'containerOverrides': [
            {
                'name': container,
                'command': command,
            },
        ],
    },
    dag=dag,
)

task.set_upstream(...)
task.set_downstream(...)

airflow scheduler