celery.apps.beat

celery.apps.beat

This module is the ‘program-version’ of celery.beat.

It does everything necessary to run that module as an actual application, like installing signal handlers and so on.

class celery.apps.beat.Beat(max_interval=None, app=None, socket_timeout=30, pidfile=None, no_color=None, loglevel=None, logfile=None, schedule=None, scheduler_cls=None, redirect_stdouts=None, redirect_stdouts_level=None, \*kwargs*)[源代码]

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

    • get_scheduler(lazy=False)

    • scheduler None

    • scheduler_cls

      PersistentScheduler 的别名

    • start(embedded_process=False)

    • stop(wait=False)

    • sync()

  • Beat.app = None

  • Beat.init_loader()[源代码]

  • Beat.install_sync_handler(beat)[源代码]

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

  • Beat.run()[源代码]

  • Beat.set_process_title()[源代码]

  • Beat.setup_logging(colorize=None)[源代码]

  • Beat.start_scheduler()[源代码]

  • Beat.startup_info(beat)[源代码]