azkaban_cli/azkaban.py
def fetch_execution_job_log(self, execution_id, jobid, offset, length):
        """Fetches the correponding job logs.

        This method receives the execution id, jobid, offset and lenght, makes a fetch
        request to get the correponding job logs and evaluates the response.

        Returns the json response from the request.

        :param execution_id: Execution id on Azkaban
        :type execution_id: str
        :param jobid: The unique id for the job to be fetched.
        :type jobid: str
        :param offset: The offset for the log data.
        :type offset: str
        :param length: The length of the log data. For example, if the offset set is
         10 and the length is 1000, the returned log will starts from the 10th character
         and has a length of 1000 (less if the remaining log is less than 1000 long)
        :type length: str
        :raises FetchExecutionJobsLogError: when Azkaban api returns error in response
        """

        self.__check_if_logged()
        response = api.fetch_execution_job_log_request(
            self.__session,
            self.__host,
            self.__session_id,
            execution_id,
            jobid,
            offset,
            length
        )

        self.__catch_response_error(response, FetchExecutionJobsLogError)

        return response.json()
Fetches the correponding job logs.

        This method receives the execution id, jobid, offset and lenght, makes a fetch
        request to get the correponding job logs and evaluates the response.

        Returns the json response from the request.

        :param execution_id: Execution id on Azkaban
        :type execution_id: str
        :param jobid: The unique id for the job to be fetched.
        :type jobid: str
        :param offset: The offset for the log data.
        :type offset: str
        :param length: The length of the log data. For example, if the offset set is
         10 and the length is 1000, the returned log will starts from the 10th character
         and has a length of 1000 (less if the remaining log is less than 1000 long)
        :type length: str
        :raises FetchExecutionJobsLogError: when Azkaban api returns error in response
        
Fetches the correponding job logs.
This method receives the execution id, jobid, offset and lenght, makes a fetch
request to get the correponding job logs and evaluates the response.

Returns the json response from the request.
Fetches the correponding job logs . This method receives the execution id jobid offset and lenght makes a fetch request to get the correponding job logs and evaluates the response . Returns the json response from the request .
def fetch_execution_job_log(self, execution_id, jobid, offset, length):
        self.__check_if_logged()
        response = api.fetch_execution_job_log_request(
            self.__session,
            self.__host,
            self.__session_id,
            execution_id,
            jobid,
            offset,
            length
        )
        self.__catch_response_error(response, FetchExecutionJobsLogError)
        return response.json()
def fetch_execution_job_log ( self , execution_id , jobid , offset , length ) : self . __check_if_logged ( ) response = api . fetch_execution_job_log_request ( self . __session , self . __host , self . __session_id , execution_id , jobid , offset , length ) self . __catch_response_error ( response , FetchExecutionJobsLogError ) return response . json ( )
Fetches the correponding job logs.
Fetches the correponding job logs .
"""Fetches the correponding job logs.

        This method receives the execution id, jobid, offset and lenght, makes a fetch
        request to get the correponding job logs and evaluates the response.

        Returns the json response from the request.

        :param execution_id: Execution id on Azkaban
        :type execution_id: str
        :param jobid: The unique id for the job to be fetched.
        :type jobid: str
        :param offset: The offset for the log data.
        :type offset: str
        :param length: The length of the log data. For example, if the offset set is
         10 and the length is 1000, the returned log will starts from the 10th character
         and has a length of 1000 (less if the remaining log is less than 1000 long)
        :type length: str
        :raises FetchExecutionJobsLogError: when Azkaban api returns error in response
        """
when Azkaban api returns error in response
when Azkaban api returns error in response
FetchExecutionJobsLogError
self
execution_id
Execution id on Azkaban
Execution id on Azkaban
jobid
The unique id for the job to be fetched.
The unique id for the job to be fetched .
offset
The offset for the log data.
The offset for the log data .
length
The length of the log data. For example, if the offset set is
10 and the length is 1000, the returned log will starts from the 10th character
and has a length of 1000 (less if the remaining log is less than 1000 long)
The length of the log data . For example if the offset set is 10 and the length is 1000 the returned log will starts from the 10th character and has a length of 1000 ( less if the remaining log is less than 1000 long )