Run your Deployment's current Airflow image

import os
from airflow.configuration import conf
from airflow.providers.cncf.kubernetes.operators.pod import KubernetesPodOperator
from kubernetes.client import models as k8s
KubernetesPodOperator(
    namespace=conf.get("kubernetes", "NAMESPACE"),
    image=os.getenv("ASTRONOMER_AIRFLOW_IMAGE"),
    image_pull_secrets=[
        k8s.V1LocalObjectReference("image-pull-secret"),
        k8s.V1LocalObjectReference("per-dp-registry-pull-secret"),
    ],
    cmds=["<commands-for-image>"],
    arguments=["<arguments-for-image>"],
    labels={"<pod-label>": "<label-name>"},
    name="<pod-name>",
    task_id="<task-name>",
    get_logs=True,
    in_cluster=True,
)