"george@vandelay.com"), ("Cosmo Kramer", "kosmo@vandelay.com"), ) # E-mail address used as sender (From field). SERVER_EMAIL = "no-reply@vandelay.com" # Mailserver configuration EMAIL_HOST = "mail embedded). Sender is the celery.beat.Service instance. celery.signals.beat_embedded_init Dispatched in addition to the beat_init signal when celerybeat is started as an embedded process. Sender is the celery b0e) args=[2, 2] kwargs={} result=4, runtime=0.782663106918 The fields here are, in order: *sender hostname*, *timestamp*, *event type* and *additional event fields*. AMQP result backend: Now supports

Costanza", "george@vandelay.com"), ("Cosmo Kramer", "kosmo@vandelay.com"), ) # Email address used as sender (From field). SERVER_EMAIL = "no-reply@vandelay.com" # Mailserver configuration EMAIL_HOST = "mail embedded). Sender is the celery.beat.Service instance. celery.signals.beat_embedded_init Dispatched in addition to the beat_init signal when celerybeat is started as an embedded process. Sender is the celery 2b0e) args=[2, 2] kwargs={} result=4, runtime=0.782663106918 The fields here are, in order: *sender hostname*, *timestamp*, *event type* and *additional event fields*. AMQP result backend: Now supports

connect def task_sent_handler(sender=None, body=None, **kwargs): print('after_task_publish for task id {body[id]}'.format( body=body, )) Some signals also have a sender which you can filter by as a sender, so by providing the sender argument to connect you can connect your handler to be called every time a task with name “proj.tasks.add” is published: @after_task_publish.connect(sender='proj connect(sender='proj.tasks.add') def task_sent_handler(sender=None, body=None, **kwargs): print('after_task_publish for task id {body[id]}'.format( body=body, )) Signals use the same implementation as django

setup_periodic_tasks(sender, **kwargs): # Calls test('hello') every 10 seconds. sender.add_periodic_task(10.0, test.s('hello'), name='add every 10') # Calls test('world') every 30 seconds sender.add_periodic_task(30 add_periodic_task(30.0, test.s('world'), expires=10) # Executes every Monday morning at 7:30 a.m. sender.add_periodic_task( crontab(hour=7, minute=30, day_of_week=1), test.s('Happy Mondays from celery.signals import after_task_publish @after_task_publish.connect def task_sent_handler(sender=None, headers=None, body=None, **kwargs): # information about task are located in headers for

setup_periodic_tasks(sender, **kwargs): # Calls test('hello') every 10 seconds. sender.add_periodic_task(10.0, test.s('hello'), name='add every 10') # Calls test('world') every 30 seconds sender.add_periodic_task(30 add_periodic_task(30.0, test.s('world'), expires=10) # Executes every Monday morning at 7:30 a.m. sender.add_periodic_task( crontab(hour=7, minute=30, day_of_week=1), test.s('Happy Mondays from celery.signals import after_task_publish @after_task_publish.connect def task_sent_handler(sender=None, headers=None, body=None, **kwargs): # information about task are located in headers for

setup_periodic_tasks(sender, **kwargs): # Calls test('hello') every 10 seconds. sender.add_periodic_task(10.0, test.s('hello'), name='add every 10') # Calls test('world') every 30 seconds sender.add_periodic_task(30 add_periodic_task(30.0, test.s('world'), expires=10) # Executes every Monday morning at 7:30 a.m. sender.add_periodic_task( crontab(hour=7, minute=30, day_of_week=1), test.s('Happy Mondays from celery.signals import after_task_publish @after_task_publish.connect def task_sent_handler(sender=None, headers=None, body=None, **kwargs): # information about task are located in headers for

setup_periodic_tasks(sender, **kwargs): # Calls test('hello') every 10 seconds. sender.add_periodic_task(10.0, test.s('hello'), name='add every 10') # Calls test('world') every 30 seconds sender.add_periodic_task(30 add_periodic_task(30.0, test.s('world'), expires=10) # Executes every Monday morning at 7:30 a.m. sender.add_periodic_task( crontab(hour=7, minute=30, day_of_week=1), test.s('Happy Mondays from celery.signals import after_task_publish @after_task_publish.connect def task_sent_handler(sender=None, headers=None, body=None, **kwargs): # information about task are located in headers for

import Model, connect, post_save class MyModel(Model): data = IntegerField() @connect(post_save, sender=MyModel) def on_save_handler(model_class, instance, created): put_data_in_cache(instance.data) connect() method, which takes a callback function and two optional parameters for “sender” and “name”. If specified, the “sender” parameter should be a single model class and allows your callback to only receive post_save_handler(sender, instance, created): print '%s was just saved' % instance # our handler will only be called when we save instances of SomeModel post_save.connect(post_save_handler, sender=SomeModel)

"george@vandelay.com"), ("Cosmo Kramer", "kosmo@vandelay.com"), ) # E-mail address used as sender (From field). SERVER_EMAIL = "no-reply@vandelay.com" # Mailserver configuration EMAIL_HOST = "mail connecting to the task_sent signal: from celery.signals import task_sent def task_sent_handler(sender=None, task_id=None, task=None, args=None, kwargs=None, **kwds): print("Got connect(task_sent_handler) Some signals also have a sender which you can filter by. For example the task_sent signal uses the task name as a sender, so you can connect your handler to be called only when

setup_periodic_tasks(sender, **kwargs): # Calls test('hello') every 10 seconds. sender.add_periodic_task(10.0, test.s('hello'), name='add every 10') # Calls test('world') every 30 seconds sender.add_periodic_task(30 add_periodic_task(30.0, test.s('world'), expires=10) # Executes every Monday morning at 7:30 a.m. sender.add_periodic_task( crontab(hour=7, minute=30, day_of_week=1), test.s('Happy Mondays from celery.signals import after_task_publish @after_task_publish.connect def task_sent_handler(sender=None, headers=None, body=None, **kwargs): # information about task are located in headers for