code: def get_describe_pod_operator(
      cluster_name: str, pod_name: str
  ) -> Operator:
      """Returns an operator that'll print the output of a `k describe pod` in the airflow logs."""
      return BashOperator(
          task_id="describe_pod",
          bash_command=f"""
                  install_aws.sh;
                  install_kubectl.sh;
                  # configure kubectl to hit the right cluster
                  aws eks update-kubeconfig --name {cluster_name};
                  # once all this setup is done, actually describe the pod
                  echo "vvv pod description below vvv";
                  kubectl describe pod {pod_name};
                  echo "^^^ pod description above ^^^" """,
      )
  
imports: from __future__ import annotations
  from typing import TYPE_CHECKING
  from airflow.operators.bash import BashOperator
label_desc: Use image node_id 1 for calling a global function with example usage: get_describe_pod_operator(cluster_name, pod_name) and returns: BashOperator