This document describes the current stable version of Celery (3.1). For development docs,
go here.
celery.worker.autoreload
This module implements automatic module reloading
-
class celery.worker.autoreload.WorkerComponent(w, autoreload=None, **kwargs)[source]
-
conditional = True
-
create(w)[source]
-
label = 'Autoreloader'
-
name = u'celery.worker.autoreload.WorkerComponent'
-
register_with_event_loop(w, hub)[source]
-
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)[source]
Tracks changes in modules and fires reload commands
-
Monitor
alias of StatMonitor
-
body()[source]
-
on_change(files)[source]
-
on_event_loop_close(hub)[source]
-
on_init()[source]
-
register_with_event_loop(hub)[source]
-
stop()[source]
-
celery.worker.autoreload.Monitor
alias of StatMonitor
-
class celery.worker.autoreload.BaseMonitor(files, on_change=None, shutdown_event=None, interval=0.5)[source]
-
on_change(modified)[source]
-
on_event_loop_close(hub)[source]
-
start()[source]
-
stop()[source]
-
class celery.worker.autoreload.StatMonitor(files, on_change=None, shutdown_event=None, interval=0.5)[source]
File change monitor based on the stat system call.
-
find_changes()[source]
-
register_with_event_loop(hub)[source]
-
start()[source]
-
class celery.worker.autoreload.KQueueMonitor(*args, **kwargs)[source]
File change monitor based on BSD kernel event notifications
-
add_events(poller)[source]
-
close(poller)[source]
-
handle_event(events)[source]
-
on_event_loop_close(hub)[source]
-
register_with_event_loop(hub)[source]
-
start()[source]
-
stop()[source]
-
class celery.worker.autoreload.InotifyMonitor(modules, on_change=None, **kwargs)[source]
File change monitor based on Linux kernel inotify subsystem
-
create_notifier()[source]
-
on_change(modified)[source]
-
on_event_loop_close(hub)[source]
-
on_readable()[source]
-
process_(event)[source]
-
process_IN_ATTRIB(event)
-
process_IN_MODIFY(event)
-
register_with_event_loop(hub)[source]
-
start()[source]
-
stop()[source]
-
celery.worker.autoreload.file_hash(filename, algorithm='md5')[source]