 Ask Solem
|
bb19026c1c
Consumer: Removes left-over debugging statement
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
d70dae576c
Consumer: Fixes a bug where celeryd would not stop when a socket.error was raised at shutdown (it always happened after 6ae4ec75f3dfda73cc1e47e326c6fa727d1413a0)
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
6ae4ec75f3
Consumer: Adds a timeout when draining_events. The idea is that this may ensure the recv call is not stuck
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
7fd0af74d9
PEP8ify + pyflakes + tests passing
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
01487be740
Heart is now using timer2.Timer
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
fc11106b04
celeryd: basic_qos prefetch_count is a short, so can't exceed 0xffff. If this happens we disable the prefetch limit. Closes #359. Thanks to defcube
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
3bfdca1c0e
Renamed celery.worker.controllers -> celery.worker.mediator
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
58d12a0737
Removes left-over print statement
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
85c5318ecb
Spawn broadcast consumer in separate thread if running green
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
b79fedfd7c
on_decode_error now uses safe_str when dumping the message body
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
9f4a864827
Consumer: ack callback must handle AttributeError
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
1ab37bbf44
Use safe_repr to ensure repr doesn't crash the worker. Closes #298
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
9b33d52043
Keep all queues for routing purposes when selecting queue subset for consumng. Closes #319. Thanks to marcinn
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
f612848a62
PEP8ify + pyflakes
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
4fc9e9c624
Reset pidbox node on channel failure
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
25a59556f0
Replaced SharedCounter with good old fashioned mutual exclusion
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
1d1ead532f
Working implementation of celery.contrib.batches
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
24875017c7
on_decode_error: Use repr() not str(). Closes #297. Thanks to gthb
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
156c8edb02
Cosmetics and cleanup
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
1c99a986dd
100% Coverage for celery.worker.autoscale
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
dc2619088b
consumer: Fixed error 'No such attribute channel_errors'
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
6f426e5a85
[Security] inspect.stats should not transmit broker password. Closes #273
|
%!s(int64=15) %!d(string=hai) anos |
 Ask Solem
|
d455cd93ae
maybe_conn_error: Add AttributeError to the list (if connection is None)
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
c1bb5b4383
Log errors occurring while handling control commands, instead of propagating.
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
a776203bf5
Remove now unused private method worker.consumer.Consumer._mainloop
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
b0345dc457
Various eventlet related fixes (shutdown) and added a -P|--pool argument to celeryd to select pool implementation on the commandline
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
6d701544fd
Removed MethodQueue and disabled heart
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
6d255867ae
Yes! Yes! Got eventlet support working (but some small bugs to fix still)
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
935ab248c2
Handle errors occuring while acking task messages. Thanks to Chimrod.
|
%!s(int64=15) %!d(string=hai) anos |
|
Ask Solem
|
de279344fa
Consumer: Close broadcast consumer when connection is reset. Thanks to David Wolever
|
%!s(int64=15) %!d(string=hai) anos |
