 Ask Solem
|
d039ba3bdd
Fixes argument errors with fallback chords. Thanks to xoro
|
14 gadi atpakaļ |
|
Ask Solem
|
d16c9061db
PEP8ify + pyflakes
|
14 gadi atpakaļ |
|
Ask Solem
|
8f96b21689
Complex LRUCache implementation
|
14 gadi atpakaļ |
|
Ask Solem
|
f0962a90db
platforms.signals: New interface for managing process signals.
|
14 gadi atpakaļ |
|
Ask Solem
|
a40ab46dc8
Implements join_native() + iter_native() for Redis and Cache backends
|
14 gadi atpakaļ |
|
Ask Solem
|
ca43b67523
Cleans up the redis backend, configuration keys now CELERY_REDIS_* instead of REDIS_*
|
14 gadi atpakaļ |
 David Strauss
|
9b1a68db2f
Add missing parameter to stub function.
|
14 gadi atpakaļ |
|
Ask Solem
|
6cd3e95060
Implements TaskSetResult().delete (delete after save)
|
14 gadi atpakaļ |
|
Ask Solem
|
e4c7d30991
chord: Can now specify the execution options of the chord task, and the interval and max_retries arguments of the unlock task
|
14 gadi atpakaļ |
|
Ask Solem
|
332ac0fdf7
Introducing Chords (taskset callbacks)
|
14 gadi atpakaļ |
|
Ask Solem
|
9d01e788c9
Results are now disabled by default.
|
14 gadi atpakaļ |
|
Ask Solem
|
bea1ab05e6
Cosmetics
|
14 gadi atpakaļ |
|
Ask Solem
|
0a75a82d3e
Backend.store_result now passes kwargs to real implementation
|
14 gadi atpakaļ |
|
Ask Solem
|
87d7e09937
Merge branch 'cburgmer/master'
|
14 gadi atpakaļ |
|
Ask Solem
|
dfbac4a6f9
TaskSetResult.join + AsyncResult.wait improvements.
|
15 gadi atpakaļ |
 Christoph Burgmer
|
9b575d9197
Raise NotImplementedError for forget() with AMQP
|
15 gadi atpakaļ |
 Ask Solem
|
f4aefcdd0d
Removed `celery.task.RemoteExecuteTask` and accompanying functions: `dmap`, `dmap_async`, and `execute_remote`.
|
15 gadi atpakaļ |
|
Ask Solem
|
c1eb62f9d3
Cosmetics
|
15 gadi atpakaļ |
 Chris Rose
|
c266bc1877
Fix the DB backend race condition when clients access the taskmeta at the same time as the server creates it
|
15 gadi atpakaļ |
|
Ask Solem
|
0afa1efa28
Docs: Replaced all occurences of ``literal`` with `literal`
|
15 gadi atpakaļ |
|
Ask Solem
|
7a9c079440
KeyValueStoreBackend.forget: delete(key_for_task(id)) not delete(id)
|
15 gadi atpakaļ |
|
Ask Solem
|
0c8580f8e6
AsyncResult.forget: Need to remove task from BaseDictBackend cache, so backends should now define the _forget method to override how the key is deleted.
|
15 gadi atpakaļ |
|
Ask Solem
|
c1a6670656
Implemented AsyncResult.forget for sqla/cache/redis/tyrant backends. (Forget and remove task result). Closes #184. Thanks to dottedmag
|
15 gadi atpakaļ |
|
Ask Solem
|
7f082a8ea8
Intense refactoring
|
15 gadi atpakaļ |
|
Ask Solem
|
b442d34c8e
Global settings removed. Still a little bit of refactoring to be done, but the tests passes now.
|
15 gadi atpakaļ |
|
Ask Solem
|
5c962c8101
WorkerTaskTrace now includes more metadata for the STARTED state: pid and hostname of the worker that started the task.
|
15 gadi atpakaļ |
|
Ask Solem
|
a1f4e2989c
AsyncResult.traceback: Return None, not raise KeyError if missing traceback.
|
15 gadi atpakaļ |
 Jonas Haag
|
4e9d87b95c
Make .store_result function if 'state' is not known to celery.
|
15 gadi atpakaļ |
|
Ask Solem
|
5670936e51
Remove some more hardcoded usage of .conf
|
15 gadi atpakaļ |
|
Ask Solem
|
d6e489fee7
Backends: Removed is_successful(), replaced by AsyncResult.success().
|
15 gadi atpakaļ |
