ecsjobs.runner module

class ecsjobs.runner.EcsJobsRunner(config, only_email_if_problems=False)[source]

Bases: object

_poll_jobs()[source]

Poll the jobs in self._running; if they’re finished, move the Job to self._finished.

_report()[source]

Generate and send email report.

_run_jobs(jobs, force_run=False)[source]

Run the specified jobs.

Parameters:
  • jobs (list) – list of Job instances to run
  • force_run (bool) – Run each job regardless of cron expression
run_job_names(job_names)[source]

Run the named jobs, regardless of schedule.

Parameters:job_names (list) – list of string job names to run
run_schedules(schedule_names)[source]

Run the named schedules.

Parameters:schedule_names (list) – names of the schedules to run
ecsjobs.runner.main(argv=None)[source]
ecsjobs.runner.parse_args(argv)[source]
ecsjobs.runner.set_log_debug(logger)[source]

set logger level to DEBUG, and debug-level output format, via set_log_level_format().

ecsjobs.runner.set_log_info(logger)[source]

set logger level to INFO via set_log_level_format().

ecsjobs.runner.set_log_level_format(logger, level, format)[source]

Set logger level and format.

Parameters:
  • logger (logging.Logger) – the logger object to set on
  • level (int) – logging level; see the logging constants.
  • format (str) – logging formatter format string