 Ask Solem
|
116ccc1f97
celery.bin.base: Cosmetics
|
пре 14 година |
|
Ask Solem
|
71c2f5499a
multiprocessing.Pool: Fixes race condition with WorkerLostError.
|
пре 14 година |
|
Ask Solem
|
711d349996
Use multiprocessing.register_after_fork to deal with fork cleanup
|
пре 14 година |
|
Ask Solem
|
ad6e53a02f
beat: Cosmetics
|
пре 14 година |
|
Ask Solem
|
c8efe314bd
celerybeat: Respect --pidfile even if not --detach. Closes #363
|
пре 14 година |
|
Ask Solem
|
4a12e1c2ae
Forgot to import celery.signals
|
пре 14 година |
|
Ask Solem
|
9c04913c9d
Adds signals: eventlet_pool_started, eventlet_pool_preshutdown, eventlet_pool_postshutdown, eventlet_pool_apply
|
пре 14 година |
|
Ask Solem
|
faf48837e9
Tests passes again
|
пре 14 година |
|
Ask Solem
|
3bfdca1c0e
Renamed celery.worker.controllers -> celery.worker.mediator
|
пре 14 година |
|
Ask Solem
|
ac0baa5542
Threads must call os._exit to terminate the server on crash
|
пре 14 година |
|
Ask Solem
|
e71a89c22d
Merge branch 'stipa/master'
|
пре 14 година |
|
Ask Solem
|
fa2cd0b3b8
Tests passing
|
пре 14 година |
|
Ask Solem
|
f944b8c169
Fixed typo seconds=int, seconds=delta. Closes #352. Thanks to LawrenceK
|
пре 14 година |
|
Ask Solem
|
da74cd1ed3
broadcast commands should not log with level warning
|
пре 14 година |
 Ryan Petrello
|
3bb7227c54
Fixing a bug.
|
пре 14 година |
|
Ryan Petrello
|
443751b84c
Changing the `BROKER_BACKEND_EXTRA_ARGS ` config option to `BROKER_TRANSPORT_OPTIONS`.
|
пре 14 година |
|
Ask Solem
|
8756fd39d8
Functional tests passing again
|
пре 14 година |
|
Ryan Petrello
|
def7d5b966
Adding support for the `BROKER_BACKEND_EXTRA_ARGS` configuration option, an optional dict() which can be used to pass connection arguments to alternative broker implementations (like `sqlakombu`).
|
пре 14 година |
|
Ryan Petrello
|
d860590da8
Adding support for the `BROKER_BACKEND_EXTRA_ARGS` configuration option, an optional dict() which can be used to pass connection arguments to alternative broker implementations (like `sqlakombu`).
|
пре 14 година |
|
Ask Solem
|
ab301c2004
AMQP result backend: Reset cached chan on producer when connection lost
|
пре 14 година |
|
Ask Solem
|
d4a46861e7
Adds worker_pid to TaskRequest.info()
|
пре 14 година |
|
Ask Solem
|
8dc7051de0
Don't sleep when the bucket is empty, rather wait for a task to be received
|
пре 14 година |
|
Ask Solem
|
0cc9cb7835
PEP8ify + pyflakes
|
пре 14 година |
|
Ask Solem
|
5ca6bee22d
Tests passes again
|
пре 14 година |
 stipa
|
67def1ea77
Add error handling when reading corrupted shelve file
|
пре 14 година |
|
Ask Solem
|
bba695e5ba
Show proper error message for commands that doesn't support positional args
|
пре 14 година |
|
Ask Solem
|
6b91c7e0f2
Try to fix #315
|
пре 14 година |
|
Ask Solem
|
309e15a099
Autoscaler: Changes all process busy message to be a debug message
|
пре 14 година |
 jpellerin
|
2cdd1d8c3d
Autoscaler: log warning instead of error when unable to scale down due to busy processes.
|
пре 14 година |
|
Ask Solem
|
e5252c1bec
Beat: PersistentScheduler: Automatically remove corrupted db. Closes #346. Thanks to stipa
|
пре 14 година |
