This document describes an older version of Celery (2.2). For the latest stable version please go here.

celery.apps.beat

class celery.apps.beat.Beat(loglevel=None, logfile=None, schedule=None, max_interval=None, scheduler_cls=None, app=None, socket_timeout=30, redirect_stdouts=None, redirect_stdouts_level=None, pidfile=None, **kwargs)

class Service(logger=None, max_interval=None, schedule_filename=None, scheduler_cls=None, app=None)

get_scheduler(lazy=False)

scheduler

scheduler_cls

alias of PersistentScheduler

start(embedded_process=False)

stop(wait=False)

sync()

Beat.init_loader()

Beat.install_sync_handler(beat)

Install a SIGTERM + SIGINT handler that saves the celerybeat schedule.

Beat.run()

Beat.set_process_title()

Beat.setup_logging()

Beat.start_scheduler(logger=None)

Beat.startup_info(beat)