beat.web.backend.local_scheduler module

class beat.web.backend.local_scheduler.SchedulerProcess(arguments, queue=None)

Bases: multiprocessing.context.Process

run()

Method to be run in sub-process; can be overridden in sub-class

class beat.web.backend.local_scheduler.WorkerProcess(arguments, queue=None)

Bases: multiprocessing.context.Process

run()

Method to be run in sub-process; can be overridden in sub-class

beat.web.backend.local_scheduler.start_scheduler(settings_module='beat.web.settings.settings', interval=5, address='127.0.0.1', port=50000)

beat.web.backend.local_scheduler.start_worker(name, prefix, cache, scheduler_address, use_docker=False)

beat.web.backend.local_scheduler.stop_process(pid)