airflow/contrib/hooks/qubole_hook.py
def get_jobs_id(self, ti):
        """
        Get jobs associated with a Qubole commands
        :param ti: Task Instance of the dag, used to determine the Quboles command id
        :return: Job information associated with command
        """
        if self.cmd is None:
            cmd_id = ti.xcom_pull(key="qbol_cmd_id", task_ids=self.task_id)
        Command.get_jobs_id(self.cls, cmd_id)
def get_jobs_id(self, ti):
        """
        Get jobs associated with a Qubole commands
        :param ti: Task Instance of the dag, used to determine the Quboles command id
        :return: Job information associated with command
        """
        if self.cmd is None:
            cmd_id = ti.xcom_pull(key="qbol_cmd_id", task_ids=self.task_id)
        Command.get_jobs_id(self.cls, cmd_id)
def get_jobs_id ( self , ti ) : if self . cmd is None : cmd_id = ti . xcom_pull ( key = "qbol_cmd_id" , task_ids = self . task_id ) Command . get_jobs_id ( self . cls , cmd_id )
Get jobs associated with a Qubole commands
        :param ti: Task Instance of the dag, used to determine the Quboles command id
        :return: Job information associated with command
Get jobs associated with a Qubole commands : param ti : Task Instance of the dag used to determine the Quboles command id : return : Job information associated with command