def run_pod(self, pod, startup_timeout=<NUM_LIT>, get_logs=True):<EOL>
resp = self.run_pod_async(pod)<EOL>curr_time = dt.now()<EOL>if resp.status.start_time is None:<EOL><INDENT>while self.pod_not_started(pod):<EOL><INDENT>delta = dt.now() - curr_time<EOL>if delta.seconds >= startup_timeout:<EOL><INDENT>raise AirflowException("<STR_LIT>")<EOL><DEDENT>time.sleep(<NUM_LIT:1>)<EOL><DEDENT>self.log.debug('<STR_LIT>')<EOL><DEDENT>return self._monitor_pod(pod, get_logs)<EOL>
Launches the pod synchronously and waits for completion.
Args:
    pod (Pod):
    startup_timeout (int): Timeout for startup of the pod (if pod is pending for
     too long, considers task a failure