azkaban_cli/azkaban.py
def fetch_running_executions_of_a_flow(self, project, flow):
        """Fetch running executions of a flow command, intended to make the request to Azkaban
        and treat the response properly.

        This method receives the project name and the flow id, making the fetch and evaluating the response.

        Returns the json response from the request.

        :param project: Project name on Azkaban
        :type project: str
        :param flow: Flow id on Azkaban
        :type flow: str
        :raises FetchRunningExecutionsOfAFlowError: when Azkaban api returns error in response
        """

        self.__check_if_logged()

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

        self.__catch_response_error(response, FetchRunningExecutionsOfAFlowError)

        return response.json()
Fetch running executions of a flow command, intended to make the request to Azkaban
        and treat the response properly.

        This method receives the project name and the flow id, making the fetch and evaluating the response.

        Returns the json response from the request.

        :param project: Project name on Azkaban
        :type project: str
        :param flow: Flow id on Azkaban
        :type flow: str
        :raises FetchRunningExecutionsOfAFlowError: when Azkaban api returns error in response
        
Fetch running executions of a flow command, intended to make the request to Azkaban
and treat the response properly.

This method receives the project name and the flow id, making the fetch and evaluating the response.

Returns the json response from the request.
Fetch running executions of a flow command intended to make the request to Azkaban and treat the response properly . This method receives the project name and the flow id making the fetch and evaluating the response . Returns the json response from the request .
def fetch_running_executions_of_a_flow(self, project, flow):
        self.__check_if_logged()
        response = api.fetch_running_executions_of_a_flow_request(
            self.__session,
            self.__host,
            self.__session_id,
            project,
            flow,
        )
        self.__catch_response_error(response, FetchRunningExecutionsOfAFlowError)
        return response.json()
def fetch_running_executions_of_a_flow ( self , project , flow ) : self . __check_if_logged ( ) response = api . fetch_running_executions_of_a_flow_request ( self . __session , self . __host , self . __session_id , project , flow , ) self . __catch_response_error ( response , FetchRunningExecutionsOfAFlowError ) return response . json ( )
Fetch running executions of a flow command, intended to make the request to Azkaban
and treat the response properly.
Fetch running executions of a flow command intended to make the request to Azkaban and treat the response properly .
"""Fetch running executions of a flow command, intended to make the request to Azkaban
        and treat the response properly.

        This method receives the project name and the flow id, making the fetch and evaluating the response.

        Returns the json response from the request.

        :param project: Project name on Azkaban
        :type project: str
        :param flow: Flow id on Azkaban
        :type flow: str
        :raises FetchRunningExecutionsOfAFlowError: when Azkaban api returns error in response
        """
when Azkaban api returns error in response
when Azkaban api returns error in response
FetchRunningExecutionsOfAFlowError
self
project
Project name on Azkaban
Project name on Azkaban
flow
Flow id on Azkaban
Flow id on Azkaban