| .. |
|
__init__.py
|
167c00f7e1
Worker: Now uses WorkerShutdown instead of SystemTerminate so that gevent/eventlet can distinguish from "WorkerLostError"
|
před 11 roky |
|
autoreload.py
|
a50d1cd549
Tests pass on PyPy
|
před 12 roky |
|
autoscale.py
|
79b3b1877c
Autoscale/grow: Fixes prefetch count updates
|
před 12 roky |
|
components.py
|
4323144a9e
Fixes typo app.clock.lock -> app.clock.mutex
|
před 11 roky |
|
consumer.py
|
e405f0693a
Gossip: Drop any task related events received by mistake (Issue #1882)
|
před 11 roky |
|
control.py
|
167c00f7e1
Worker: Now uses WorkerShutdown instead of SystemTerminate so that gevent/eventlet can distinguish from "WorkerLostError"
|
před 11 roky |
|
heartbeat.py
|
610b1a7657
worker.heartbeat: Update 'interval' doc default to 2 seconds
|
před 11 roky |
|
job.py
|
ecbf23a568
Task: Do not send error emails for expected errors (@task(throws=...))
|
před 11 roky |
|
loops.py
|
fa7ad41fa4
Use Connection.get_heartbeat_interval()
|
před 11 roky |
|
pidbox.py
|
4d71c3c9e4
Pidbox now always sets accept encoding to json only. Closes #1870
|
před 11 roky |
|
state.py
|
167c00f7e1
Worker: Now uses WorkerShutdown instead of SystemTerminate so that gevent/eventlet can distinguish from "WorkerLostError"
|
před 11 roky |
|
strategy.py
|
1eb681c4cf
Wording: Got task from broker -> Received task
|
před 12 roky |
Ask Solem
ecbf23a568
Task: Do not send error emails for expected errors (@task(throws=...))