我在 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