This document describes the current stable version of Celery (3.1). For development docs, go here.

celery.worker.autoreload

celery.worker.autoreload

This module implements automatic module reloading

class celery.worker.autoreload.WorkerComponent(w, autoreload=None, **kwargs)

conditional = True

create(w)

label = 'Autoreloader'

name = u'celery.worker.autoreload.WorkerComponent'

register_with_event_loop(w, hub)

requires = (step:celery.worker.components.Pool{(step:celery.worker.components.Queues{(step:celery.worker.components.Hub{(step:celery.worker.components.Timer{()},)},)},)},)

class celery.worker.autoreload.Autoreloader(controller, modules=None, monitor_cls=None, **options)

Tracks changes in modules and fires reload commands

Monitor

alias of StatMonitor

body()

on_change(files)

on_event_loop_close(hub)

on_init()

register_with_event_loop(hub)

stop()

celery.worker.autoreload.Monitor

alias of StatMonitor

class celery.worker.autoreload.BaseMonitor(files, on_change=None, shutdown_event=None, interval=0.5)

on_change(modified)

on_event_loop_close(hub)

start()

stop()

class celery.worker.autoreload.StatMonitor(files, on_change=None, shutdown_event=None, interval=0.5)

File change monitor based on the stat system call.

find_changes()

register_with_event_loop(hub)

start()

class celery.worker.autoreload.KQueueMonitor(*args, **kwargs)

File change monitor based on BSD kernel event notifications

add_events(poller)

close(poller)

handle_event(events)

on_event_loop_close(hub)

register_with_event_loop(hub)

start()

stop()

class celery.worker.autoreload.InotifyMonitor(modules, on_change=None, **kwargs)

File change monitor based on Linux kernel inotify subsystem

create_notifier()

on_change(modified)

on_event_loop_close(hub)

on_readable()

process_(event)

process_IN_ATTRIB(event)

process_IN_MODIFY(event)

register_with_event_loop(hub)

start()

stop()

celery.worker.autoreload.file_hash(filename, algorithm='md5')