| .. |
|
app
|
0ffbaaf7dd
Task methods now works with ALWAYS_EAGER. Closes #1478
|
il y a 12 ans |
|
apps
|
118b300fca
Don't fork on HUP to preserve PID for process supervisors
|
il y a 12 ans |
|
backends
|
6b8b3aea75
Various fixes
|
il y a 12 ans |
|
bin
|
a62af241c5
Celery control pol_grow, etc should coerce to int types
|
il y a 12 ans |
|
concurrency
|
9fe795e137
Use time.monotonic when available
|
il y a 12 ans |
|
contrib
|
d1fe473d03
Setuptools extras replaces the bundles concept
|
il y a 12 ans |
|
events
|
9fe795e137
Use time.monotonic when available
|
il y a 12 ans |
|
fixups
|
154b574809
__all__ is everywhere
|
il y a 13 ans |
|
loaders
|
29a2204b03
DefaultLoader.read_configuration now supports fail_silently argument
|
il y a 13 ans |
|
security
|
cac1d1893f
Wording
|
il y a 12 ans |
|
task
|
cac1d1893f
Wording
|
il y a 12 ans |
|
tests
|
551546ceae
moving initial_prefetch_count to consumer from tasks step
|
il y a 12 ans |
|
utils
|
1d04b51160
fixed __bool__
|
il y a 12 ans |
|
worker
|
551546ceae
moving initial_prefetch_count to consumer from tasks step
|
il y a 12 ans |
|
__init__.py
|
cac1d1893f
Wording
|
il y a 12 ans |
|
__main__.py
|
6354343554
Importing .concurrency.eventlet|gevent no longer applies monkey patches
|
il y a 13 ans |
|
_state.py
|
154b574809
__all__ is everywhere
|
il y a 13 ans |
|
beat.py
|
9fe795e137
Use time.monotonic when available
|
il y a 12 ans |
|
bootsteps.py
|
045f86759f
Bootsteps: send_all should not propagate errors
|
il y a 12 ans |
|
canvas.py
|
832a3c59a7
Canvas: All signatures now supports app argument
|
il y a 13 ans |
|
datastructures.py
|
9fe795e137
Use time.monotonic when available
|
il y a 12 ans |
|
exceptions.py
|
2ed2b3875c
Renames RetryTaskError -> Retry (backwards compatible)
|
il y a 12 ans |
|
five.py
|
9fe795e137
Use time.monotonic when available
|
il y a 12 ans |
|
local.py
|
154b574809
__all__ is everywhere
|
il y a 13 ans |
|
platforms.py
|
b80a8e35fa
Doc fixes
|
il y a 12 ans |
|
result.py
|
9fe795e137
Use time.monotonic when available
|
il y a 12 ans |
|
schedules.py
|
8e9c1ef505
Eta/expires in message must have timezone set
|
il y a 12 ans |
|
signals.py
|
a7226fa158
Pass job.Request instance to task_revoked signal. Closes #1555
|
il y a 12 ans |
|
states.py
|
67e221a024
Adds Reject exception to reject or requeue the message. Closes #1383
|
il y a 12 ans |
Dan
551546ceae
moving initial_prefetch_count to consumer from tasks step