forked from celery/celery
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathTODO
33 lines (21 loc) · 1.1 KB
/
TODO
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
Please see our Issue Tracker at GitHub:
http://github.com/celery/celery/issues
- Widelane
- Task logs errors + sends_events in the child processes
- Move non-complex object message fields from the body
to properties/application headers (task-message-format-v2)
- this means that the worker will not have to deserialize
payload to inspect these fields, and as such we may
avoid the double depickling happening in the Main- and child
processes.
- Change worker internals to support applying a list
of tasks instead of going task-by-task.
- Buffering and calling map on tasks of the same type
received in a short timeframe.
- Also buffer acks(?)
- This may also enable automatic batching alá celery.contrib.batches(?)
- job.TaskRequest may be changed to a namedtuple instead, minimizing
memory overhead, and will probably be faster too.
- though this begs the question how and where the Request's methods will
be implemented(?), some are easy to move to functions but others
are not so fortunate.