如何从GCP composer (DAG)执行Bash脚本(存在于Compute engine VM中)？

from airflow import DAG
from airflow.providers.google.cloud.operators.bash import BashOperator
from datetime import datetime

default_args = {
    'owner': 'airflow',
    'start_date': datetime(2023, 1, 1),
}

dag = DAG(
    'execute_bash_script',
    default_args=default_args,
    schedule_interval='@daily',
)

bash_task = BashOperator(
    task_id='run_bash_script',
    bash_command='gcloud compute ssh vm-instance --zone us-central1-a --command "/path/to/script.sh"',
    dag=dag,
)

from airflow import DAG
from airflow.providers.google.cloud.operators.compute import ComputeEngineOperator
from airflow.operators.python_operator import PythonOperator
from datetime import datetime

default_args = {
    'owner': 'airflow',
    'start_date': datetime(2023, 1, 1),
}

dag = DAG(
    'execute_bash_script',
    default args=default_args,
    schedule_interval='@daily',
)

def run_bash_script():
    import subprocess
    subprocess.run(['gcloud', 'compute', 'ssh', 'vm-instance', '--zone', 'us-central1-a', '--command', '/path/to/script.sh'])

python_task = PythonOperator(
    task_id='run_bash_script',
    python_callable=run_bash_script,
    dag=dag,
)