| .. |
|
control
|
8891626c9d
New remote control command: Diagnose. Verify that the pool workers are able to accept and perform tasks.
|
%!s(int64=14) %!d(string=hai) anos |
|
__init__.py
|
ee8e04d4e3
PEP8ify + pyflakes
|
%!s(int64=14) %!d(string=hai) anos |
|
buckets.py
|
89d123fd1f
worker.buckets.TaskBucket.get: Honor timeout argument and wait for item available in one of the queues.
|
%!s(int64=14) %!d(string=hai) anos |
|
controllers.py
|
006960912e
Mediator: Don't sleep between gets (reduces CPU usage considerably when rate limits activated)
|
%!s(int64=14) %!d(string=hai) anos |
|
heartbeat.py
|
f2911e4a5d
joining of threads broke the tests
|
%!s(int64=15) %!d(string=hai) anos |
|
job.py
|
5c962c8101
WorkerTaskTrace now includes more metadata for the STARTED state: pid and hostname of the worker that started the task.
|
%!s(int64=14) %!d(string=hai) anos |
|
listener.py
|
be01033687
Bug in previous commit if consumer is None
|
%!s(int64=14) %!d(string=hai) anos |
|
state.py
|
e24d6ae3b6
Use set.discard instead of set.remove
|
%!s(int64=14) %!d(string=hai) anos |
Ask Solem
5c962c8101
WorkerTaskTrace now includes more metadata for the STARTED state: pid and hostname of the worker that started the task.