airflow/contrib/hooks/qubole_hook.py
def kill(self, ti):
        """
        Kill (cancel) a Qubole command
        :param ti: Task Instance of the dag, used to determine the Quboles command id
        :return: response from Qubole
        """
        if self.cmd is None:
            if not ti and not self.task_instance:
                raise Exception("Unable to cancel Qubole Command, context is unavailable!")
            elif not ti:
                ti = self.task_instance
            cmd_id = ti.xcom_pull(key="qbol_cmd_id", task_ids=ti.task_id)
            self.cmd = self.cls.find(cmd_id)
        if self.cls and self.cmd:
            self.log.info('Sending KILL signal to Qubole Command Id: %s', self.cmd.id)
            self.cmd.cancel()
def kill(self, ti):
        """
        Kill (cancel) a Qubole command
        :param ti: Task Instance of the dag, used to determine the Quboles command id
        :return: response from Qubole
        """
        if self.cmd is None:
            if not ti and not self.task_instance:
                raise Exception("Unable to cancel Qubole Command, context is unavailable!")
            elif not ti:
                ti = self.task_instance
            cmd_id = ti.xcom_pull(key="qbol_cmd_id", task_ids=ti.task_id)
            self.cmd = self.cls.find(cmd_id)
        if self.cls and self.cmd:
            self.log.info('Sending KILL signal to Qubole Command Id: %s', self.cmd.id)
            self.cmd.cancel()
def kill ( self , ti ) : if self . cmd is None : if not ti and not self . task_instance : raise Exception ( "Unable to cancel Qubole Command, context is unavailable!" ) elif not ti : ti = self . task_instance cmd_id = ti . xcom_pull ( key = "qbol_cmd_id" , task_ids = ti . task_id ) self . cmd = self . cls . find ( cmd_id ) if self . cls and self . cmd : self . log . info ( 'Sending KILL signal to Qubole Command Id: %s' , self . cmd . id ) self . cmd . cancel ( )
Kill (cancel) a Qubole command
        :param ti: Task Instance of the dag, used to determine the Quboles command id
        :return: response from Qubole
Kill ( cancel ) a Qubole command : param ti : Task Instance of the dag used to determine the Quboles command id : return : response from Qubole