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

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

        Returns the json response from the request.

        :param str execution_id: Execution id on Azkaban
        :raises FetchFlowExecutionError: when Azkaban api returns error in response
        """

        self.__check_if_logged()

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

        self.__catch_response_error(response, FetchFlowExecutionError)

        return response.json()

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

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

        Returns the json response from the request.

        :param str execution_id: Execution id on Azkaban
        :raises FetchFlowExecutionError: when Azkaban api returns error in response
        
Fetch a flow execution command, intended to make the request to Azkaban
and treat the response properly.

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

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

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

        Returns the json response from the request.

        :param str execution_id: Execution id on Azkaban
        :raises FetchFlowExecutionError: when Azkaban api returns error in response
        """
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