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

App: Periodic Task Scheduler - celery.apps.beat

class celery.apps.beat.Beat(loglevel=None, logfile=None, schedule=None, max_interval=None, scheduler_cls=None, defaults=None, socket_timeout=30, redirect_stdouts=None, redirect_stdouts_level=None, **kwargs)
class Service(logger=None, max_interval=300, schedule={'celery.backend_cleanup': {'task': 'celery.backend_cleanup', 'schedule': <crontab: 00 04 * (m/h/d)>}}, schedule_filename='celerybeat-schedule', scheduler_cls=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)
celery.apps.beat.run_celerybeat(*args, **kwargs)

Previous topic

App: Worker Node - celery.apps.worker

Next topic

Base Command - celery.bin.base

This Page