-
Notifications
You must be signed in to change notification settings - Fork 0
/
signals.py
135 lines (119 loc) · 3.93 KB
/
signals.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
from celery import signals
#http://docs.celeryproject.org/en/latest/userguide/signals.html#id6
#
# "Signals allows decoupled applications to receive notifications
# when certain actions occur elsewhere in the application."
#
import pdb
# Producer - executed in the process sending the task
#@signals.before_task_publish.connect
#def task_before_task_publish(sender=None, headers=None, body=None, **kwargs):
# pdb.set_trace()
# d = { 'sender': sender, 'headers': headers, 'body': body }
# d.update(kwargs)
# print('signal before_task_publish received:')
# print(d)
# print
# Producer - executed in the process sending the task
#@signals.after_task_publish.connect
#def task_after_task_publish(sender=None, headers=None, body=None, **kwargs):
# d = { 'sender': sender, 'headers': headers, 'body': body }
# d.update(kwargs)
# print('signal after_task_publish received:')
# print(d)
# print
# Worker
@signals.task_prerun.connect
def task_task_prerun(sender=None, headers=None, body=None, **kwargs):
d = { 'sender': sender, 'headers': headers, 'body': body }
d.update(kwargs)
print('signal task_prerun received:')
print(d)
print
# Worker
@signals.task_postrun.connect
def task_task_postrun(sender=None, headers=None, body=None, **kwargs):
d = { 'sender': sender, 'headers': headers, 'body': body }
d.update(kwargs)
print('signal task_postrun received:')
print(d)
print
# Worker
@signals.task_success.connect
def task_task_success(sender=None, headers=None, body=None, **kwargs):
d = { 'sender': sender, 'headers': headers, 'body': body }
d.update(kwargs)
print('signal task_success received:')
print(d)
print
# Worker
@signals.task_failure.connect
def task_task_failure(sender=None, headers=None, body=None, **kwargs):
d = { 'sender': sender, 'headers': headers, 'body': body }
d.update(kwargs)
print('signal task_failure received:')
print(d)
print
# MainProcess
@signals.task_revoked.connect
def task_task_revoked(sender=None, headers=None, body=None, **kwargs):
d = { 'sender': sender, 'headers': headers, 'body': body }
d.update(kwargs)
print('signal task_revoked received:')
print(d)
print
@signals.celeryd_after_setup.connect
def worker_celeryd_after_setup(sender=None, instance=None, **kwargs):
d = { 'sender': sender, 'instance': instance }
d.update(kwargs)
print('signal celeryd_after_setup received:')
print(d)
print
# Exception out
#@signals.celeryd_init.connect
#def worker_celeryd_init(sender=None, instance=None, **kwargs):
# d = { 'sender': sender, 'instance': instance }
# d.update(kwargs)
# print('signal celeryd_init received:')
# print(d)
# print
# Exception out
#@signals.worker_init.connect
#def worker_worker_init(sender=None, instance=None, **kwargs):
# d = { 'sender': sender, 'instance': instance }
# d.update(kwargs)
# print('signal worker_init received:')
# print(d)
# print
# MainProcess
@signals.worker_ready.connect
def worker_worker_ready(sender=None, instance=None, **kwargs):
d = { 'sender': sender, 'instance': instance }
d.update(kwargs)
print('signal worker_ready received:')
print(d)
print
# Worker
@signals.worker_process_init.connect
def worker_worker_process_init(sender=None, instance=None, **kwargs):
d = { 'sender': sender, 'instance': instance }
d.update(kwargs)
print('signal worker_process_init received:')
print(d)
print
# Worker
@signals.worker_process_shutdown.connect
def worker_worker_process_shutdown(sender=None, instance=None, **kwargs):
d = { 'sender': sender, 'instance': instance }
d.update(kwargs)
print('signal worker_process_shutdown received:')
print(d)
print
# MainProcess
@signals.worker_shutdown.connect
def worker_worker_shutdown(sender=None, instance=None, **kwargs):
d = { 'sender': sender, 'instance': instance }
d.update(kwargs)
print('signal worker_shutdown received:')
print(d)
print