azkaban_cli/azkaban.py
def fetch_flow_execution_updates(self, execution_id, last_update_time):
        """
        Fetch a flow execution updates command, intended to make the request to Azkaban
        and treat the response properly.

        This method receives the execution id and the last_update_time , makes the fetch a
        flow execution request to fetch the flow execution update details and evaluates the response.

        Returns the json response from the request.

        :param str execution_id: Execution id on Azkaban
        :param str last_update_time: (optional) The criteria to filter by last update time.
        Set the value to be -1 if all job information are needed. Use -lt="value"
        to subscribe the default value, defaults to -1
        :raises FetchFlowExecutionError: when Azkaban api returns error in response
        :return class:`Response` object as json friendly.
        """

        self.__check_if_logged()

        response = api.fetch_flow_execution_updates_request(
            self.__session,
            self.__host,
            self.__session_id,
            execution_id,
            last_update_time
        )

        self.__catch_response_error(response, FetchFlowExecutionUpdatesError)

        return response.json()

        Fetch a flow execution updates command, intended to make the request to Azkaban
        and treat the response properly.

        This method receives the execution id and the last_update_time , makes the fetch a
        flow execution request to fetch the flow execution update details and evaluates the response.

        Returns the json response from the request.

        :param str execution_id: Execution id on Azkaban
        :param str last_update_time: (optional) The criteria to filter by last update time.
        Set the value to be -1 if all job information are needed. Use -lt="value"
        to subscribe the default value, defaults to -1
        :raises FetchFlowExecutionError: when Azkaban api returns error in response
        :return class:`Response` object as json friendly.
        
Fetch a flow execution updates command, intended to make the request to Azkaban
and treat the response properly.

This method receives the execution id and the last_update_time , makes the fetch a
flow execution request to fetch the flow execution update details and evaluates the response.

Returns the json response from the request.
Fetch a flow execution updates command intended to make the request to Azkaban and treat the response properly . This method receives the execution id and the last_update_time makes the fetch a flow execution request to fetch the flow execution update details and evaluates the response . Returns the json response from the request .
def fetch_flow_execution_updates(self, execution_id, last_update_time):
        self.__check_if_logged()
        response = api.fetch_flow_execution_updates_request(
            self.__session,
            self.__host,
            self.__session_id,
            execution_id,
            last_update_time
        )
        self.__catch_response_error(response, FetchFlowExecutionUpdatesError)
        return response.json()
def fetch_flow_execution_updates ( self , execution_id , last_update_time ) : self . __check_if_logged ( ) response = api . fetch_flow_execution_updates_request ( self . __session , self . __host , self . __session_id , execution_id , last_update_time ) self . __catch_response_error ( response , FetchFlowExecutionUpdatesError ) return response . json ( )
Fetch a flow execution updates command, intended to make the request to Azkaban
and treat the response properly.
Fetch a flow execution updates command intended to make the request to Azkaban and treat the response properly .
"""
        Fetch a flow execution updates command, intended to make the request to Azkaban
        and treat the response properly.

        This method receives the execution id and the last_update_time , makes the fetch a
        flow execution request to fetch the flow execution update details and evaluates the response.

        Returns the json response from the request.

        :param str execution_id: Execution id on Azkaban
        :param str last_update_time: (optional) The criteria to filter by last update time.
        Set the value to be -1 if all job information are needed. Use -lt="value"
        to subscribe the default value, defaults to -1
        :raises FetchFlowExecutionError: when Azkaban api returns error in response
        :return class:`Response` object as json friendly.
        """
`Response` object as json friendly.
` Response ` object as json friendly .
class
when Azkaban api returns error in response
when Azkaban api returns error in response
FetchFlowExecutionError
self
execution_id
Execution id on Azkaban
Execution id on Azkaban
last_update_time
(optional) The criteria to filter by last update time.
Set the value to be -1 if all job information are needed. Use -lt="value"
to subscribe the default value, defaults to -1
( optional ) The criteria to filter by last update time . Set the value to be - 1 if all job information are needed . Use - lt = " value " to subscribe the default value defaults to - 1
-1