0

我在 EC2、AWS 上使用 MWAA 气流。我有这个错误信息:第 1 行 -

*** Failed to verify remote log exists s3://airflow-xxx-xxx/logs/testedeoperadores/testebatch/2021-09-20T14:32:52.150650+00:00/1.log.

An error occurred (403) when calling the HeadObject operation: Forbidden

*** Falling back to local log

*** Reading local file: /var/log/airflow/testedeoperadores/testebatch/2021-09-20T14:32:52.150650+00:00/1.log

结束线 -

"File "/usr/lib64/python3.7/subprocess.py", line xxxx , in _execute_child
    raise child_exception_type(errno_num, err_msg, err_filename)

FileNotFoundError: [Errno 2] No such file or directory: 'bash': 'bash'

[2021-09-20 14:32:57,846] {taskinstance.py:xxx} INFO - Marking task as FAILED. dag_id=testedeoperadores, task_id=testebatch, execution_date=xxxx, start_date=xxx, end_date=xxx

[2021-09-20 14:32:58,143] {local_task_job.py:151} INFO - Task exited with return code 1

请有人知道问题是什么以及如何解决?

from airflow import DAG

from airflow.operators.bash import BashOperator

#from airflow.operators.bash_operator import BashOperator

from airflow.utils.dates import days_ago



from datetime import datetime, timedelta

import os


with DAG('testedeoperadores',start_date=days_ago(1),catchup=False)as dag:

    testebatch = BashOperator(

            task_id="testebatch",

            bash_command='echo 1'

    )

testebatch
4

0 回答 0