azkaban_cli/azkaban.py
def fetch_jobs_from_flow(self, project, flow):
        """
        Fetch jobs of a flow command, intended to make the request to Azkaban and return
        the response.

        This method receives the project name and flow id, makes the fetch jobs of a flow request
        to fetch the jobs of a flow and evaluates the response.

        Returns the json response from the request.

        :param str project: project name on Azkaban
        :param str flow: flow id on Azkaban
        :raises FetchJobsFromFlowError: when Azkaban api returns error in response
        """

        self.__check_if_logged()

        response = api.fetch_jobs_from_flow_request(
            self.__session,
            self.__host,
            self.__session_id,
            project,
            flow
        )

        self.__catch_response_error(response, FetchJobsFromFlowError)

        return response.json()

        Fetch jobs of a flow command, intended to make the request to Azkaban and return
        the response.

        This method receives the project name and flow id, makes the fetch jobs of a flow request
        to fetch the jobs of a flow and evaluates the response.

        Returns the json response from the request.

        :param str project: project name on Azkaban
        :param str flow: flow id on Azkaban
        :raises FetchJobsFromFlowError: when Azkaban api returns error in response
        
Fetch jobs of a flow command, intended to make the request to Azkaban and return
the response.

This method receives the project name and flow id, makes the fetch jobs of a flow request
to fetch the jobs of a flow and evaluates the response.

Returns the json response from the request.
Fetch jobs of a flow command intended to make the request to Azkaban and return the response . This method receives the project name and flow id makes the fetch jobs of a flow request to fetch the jobs of a flow and evaluates the response . Returns the json response from the request .
def fetch_jobs_from_flow(self, project, flow):
        self.__check_if_logged()
        response = api.fetch_jobs_from_flow_request(
            self.__session,
            self.__host,
            self.__session_id,
            project,
            flow
        )
        self.__catch_response_error(response, FetchJobsFromFlowError)
        return response.json()
def fetch_jobs_from_flow ( self , project , flow ) : self . __check_if_logged ( ) response = api . fetch_jobs_from_flow_request ( self . __session , self . __host , self . __session_id , project , flow ) self . __catch_response_error ( response , FetchJobsFromFlowError ) return response . json ( )
Fetch jobs of a flow command, intended to make the request to Azkaban and return
the response.
Fetch jobs of a flow command intended to make the request to Azkaban and return the response .
"""
        Fetch jobs of a flow command, intended to make the request to Azkaban and return
        the response.

        This method receives the project name and flow id, makes the fetch jobs of a flow request
        to fetch the jobs of a flow and evaluates the response.

        Returns the json response from the request.

        :param str project: project name on Azkaban
        :param str flow: flow id on Azkaban
        :raises FetchJobsFromFlowError: when Azkaban api returns error in response
        """
when Azkaban api returns error in response
when Azkaban api returns error in response
FetchJobsFromFlowError
self
project
project name on Azkaban
project name on Azkaban
flow
flow id on Azkaban
flow id on Azkaban