On September 15, 2026, all Cloud Composer 1 and Cloud Composer 2 version 2.0.x environments will reach their planned end of life, and you will not be able to use them. We recommend planning migration to Cloud Composer 3.
GCP_PROJECT_ID with the Project ID
of a project where the VM and the environment that runs the DAG is located.
importdatetimeimportairflowfromairflow.providers.ssh.operators.sshimportSSHOperatorfromairflow.providers.google.cloud.hooks.compute_sshimportComputeEngineSSHHookGCE_INSTANCE='example-compute-instance'GCE_ZONE='us-central1-a'GCP_PROJECT_ID='example-project'withairflow.DAG('composer_compute_ssh_dag',start_date=datetime.datetime(2022,1,1))asdag:ssh_task=SSHOperator(task_id='composer_compute_ssh_task',ssh_hook=ComputeEngineSSHHook(instance_name=GCE_INSTANCE,zone=GCE_ZONE,project_id=GCP_PROJECT_ID,use_oslogin=True,use_iap_tunnel=False,use_internal_ip=True),command='echo This command is executed from a DAG',dag=dag)
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2025-07-04 UTC."],[[["This guide explains how to establish a connection from a Directed Acyclic Graph (DAG) to a Compute Engine Virtual Machine (VM) instance, a feature available exclusively in Airflow 2."],["Utilize `ComputeEngineSSHHook` within the `ssh_hook` parameter of `SSHOperator` to configure the connection, ensuring the parameters align with the target Compute Engine VM."],["The example provided demonstrates using `SSHOperator` to execute commands on a specified Compute Engine VM instance, requiring replacement of placeholder values like `GCE_INSTANCE`, `GCE_ZONE`, and `GCP_PROJECT_ID` with actual values."],["The example code showcases how to define an SSH task that will connect to the compute engine VM and run a command."]]],[]]