azkaban_cli/azkaban.py
def schedule(self, project, flow, cron, **execution_options):
        """
        Schedule command, intended to make the request to Azkaban and treat the response properly.

        This method receives the project, the flow, the cron expression in quartz format and optional execution options,
        make the schedule request to schedule the flow with the cron specified and evaluate the response.

        If project, flow or cron is wrong or if there is no session_id, it returns false. If everything is fine, returns
        True.

        :param str project: Project name on Azkaban
        :param str flow: Flow name on Azkaban
        :param str cron: Cron expression, in quartz format [Eg.: '0*/10*?**' -> Every 10 minutes]
        :raises ScheduleError: when Azkaban api returns error in response
        """

        self.__check_if_logged()

        execution_options = {k: v for (k, v) in execution_options.items() if v}

        response = api.schedule_request(
            self.__session,
            self.__host,
            self.__session_id,
            project,
            flow,
            cron,
            **execution_options
        )

        self.__catch_response_error(response, ScheduleError)

        response_json = response.json()
        logging.info(response_json[u'message'])
        logging.info('scheduleId: %s' % (response_json[u'scheduleId']))

        Schedule command, intended to make the request to Azkaban and treat the response properly.

        This method receives the project, the flow, the cron expression in quartz format and optional execution options,
        make the schedule request to schedule the flow with the cron specified and evaluate the response.

        If project, flow or cron is wrong or if there is no session_id, it returns false. If everything is fine, returns
        True.

        :param str project: Project name on Azkaban
        :param str flow: Flow name on Azkaban
        :param str cron: Cron expression, in quartz format [Eg.: '0*/10*?**' -> Every 10 minutes]
        :raises ScheduleError: when Azkaban api returns error in response
        
Schedule command, intended to make the request to Azkaban and treat the response properly.
This method receives the project, the flow, the cron expression in quartz format and optional execution options,
make the schedule request to schedule the flow with the cron specified and evaluate the response.

If project, flow or cron is wrong or if there is no session_id, it returns false. If everything is fine, returns
True.
Schedule command intended to make the request to Azkaban and treat the response properly . This method receives the project the flow the cron expression in quartz format and optional execution options make the schedule request to schedule the flow with the cron specified and evaluate the response . If project flow or cron is wrong or if there is no session_id it returns false . If everything is fine returns True .
def schedule(self, project, flow, cron, **execution_options):
        self.__check_if_logged()
        execution_options = {k: v for (k, v) in execution_options.items() if v}
        response = api.schedule_request(
            self.__session,
            self.__host,
            self.__session_id,
            project,
            flow,
            cron,
            **execution_options
        )
        self.__catch_response_error(response, ScheduleError)
        response_json = response.json()
        logging.info(response_json[u'message'])
        logging.info('scheduleId: %s' % (response_json[u'scheduleId']))
def schedule ( self , project , flow , cron , ** execution_options ) : self . __check_if_logged ( ) execution_options = { k : v for ( k , v ) in execution_options . items ( ) if v } response = api . schedule_request ( self . __session , self . __host , self . __session_id , project , flow , cron , ** execution_options ) self . __catch_response_error ( response , ScheduleError ) response_json = response . json ( ) logging . info ( response_json [ u'message' ] ) logging . info ( 'scheduleId: %s' % ( response_json [ u'scheduleId' ] ) )
Schedule command, intended to make the request to Azkaban and treat the response properly.
Schedule command intended to make the request to Azkaban and treat the response properly .
"""
        Schedule command, intended to make the request to Azkaban and treat the response properly.

        This method receives the project, the flow, the cron expression in quartz format and optional execution options,
        make the schedule request to schedule the flow with the cron specified and evaluate the response.

        If project, flow or cron is wrong or if there is no session_id, it returns false. If everything is fine, returns
        True.

        :param str project: Project name on Azkaban
        :param str flow: Flow name on Azkaban
        :param str cron: Cron expression, in quartz format [Eg.: '0*/10*?**' -> Every 10 minutes]
        :raises ScheduleError: when Azkaban api returns error in response
        """
when Azkaban api returns error in response
when Azkaban api returns error in response
ScheduleError
self
project
Project name on Azkaban
Project name on Azkaban
flow
Flow name on Azkaban
Flow name on Azkaban
cron
Cron expression, in quartz format [Eg.: '0*/10*?**' -> Every 10 minutes]
Cron expression in quartz format [ Eg . : ' 0 * / 10 * ? ** ' - > Every 10 minutes ]