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-03 UTC."],[[["This page provides instructions on how to connect to a Compute Engine VM from a Directed Acyclic Graph (DAG)."],["The `ComputeEngineSSHHook` is used within the `ssh_hook` parameter of the `SSHOperator` to establish the connection to the Compute Engine VM."],["An example demonstrates using `SSHOperator` to execute a command on a Compute Engine VM instance."],["To make it work, users must replace `GCE_INSTANCE`, `GCE_ZONE`, and `GCP_PROJECT_ID` with their respective values."],["The content shown on this page is currently for Cloud Composer 2, and it is not yet revised for Cloud Composer 3."]]],[]]