airflow/contrib/hooks/spark_submit_hook.py
def _build_track_driver_status_command(self):
        """
        Construct the command to poll the driver status.

        :return: full command to be executed
        """
        connection_cmd = self._get_spark_binary_path()

        # The url ot the spark master
        connection_cmd += ["--master", self._connection['master']]

        # The driver id so we can poll for its status
        if self._driver_id:
            connection_cmd += ["--status", self._driver_id]
        else:
            raise AirflowException(
                "Invalid status: attempted to poll driver " +
                "status but no driver id is known. Giving up.")

        self.log.debug("Poll driver status cmd: %s", connection_cmd)

        return connection_cmd
def _build_track_driver_status_command(self):
        connection_cmd = self._get_spark_binary_path()

        # The url ot the spark master
        connection_cmd += ["--master", self._connection['master']]

        # The driver id so we can poll for its status
        if self._driver_id:
            connection_cmd += ["--status", self._driver_id]
        else:
            raise AirflowException(
                "Invalid status: attempted to poll driver " +
                "status but no driver id is known. Giving up.")

        self.log.debug("Poll driver status cmd: %s", connection_cmd)

        return connection_cmd
def _build_track_driver_status_command ( self ) : connection_cmd = self . _get_spark_binary_path ( ) # The url ot the spark master connection_cmd += [ "--master" , self . _connection [ 'master' ] ] # The driver id so we can poll for its status if self . _driver_id : connection_cmd += [ "--status" , self . _driver_id ] else : raise AirflowException ( "Invalid status: attempted to poll driver " + "status but no driver id is known. Giving up." ) self . log . debug ( "Poll driver status cmd: %s" , connection_cmd ) return connection_cmd
Construct the command to poll the driver status.

        :return: full command to be executed
Construct the command to poll the driver status .