mirror of
https://github.com/ansible/awx.git
synced 2024-11-01 08:21:15 +03:00
ff1e8cc356
this commit implements the bulk of `awx-manage run_dispatcher`, a new command that binds to RabbitMQ via kombu and balances messages across a pool of workers that are similar to celeryd workers in spirit. Specifically, this includes: - a new decorator, `awx.main.dispatch.task`, which can be used to decorate functions or classes so that they can be designated as "Tasks" - support for fanout/broadcast tasks (at this point in time, only `conf.Setting` memcached flushes use this functionality) - support for job reaping - support for success/failure hooks for job runs (i.e., `handle_work_success` and `handle_work_error`) - support for auto scaling worker pool that scale processes up and down on demand - minimal support for RPC, such as status checks and pool recycle/reload
24 lines
355 B
Plaintext
24 lines
355 B
Plaintext
django-debug-toolbar==1.5
|
|
django-rest-swagger
|
|
pprofile
|
|
ipython==5.2.1
|
|
unittest2
|
|
pep8
|
|
flake8
|
|
pluggy==0.6.0
|
|
pyflakes
|
|
pytest==3.6.0
|
|
pytest-cov
|
|
pytest-django
|
|
pytest-pythonpath
|
|
pytest-mock
|
|
pytest-timeout
|
|
pytest-xdist
|
|
logutils
|
|
jupyter
|
|
matplotlib
|
|
backports.tempfile # support in unit tests for py32+ tempfile.TemporaryDirectory
|
|
mockldap
|
|
sdb
|
|
atomicwrites==1.1.5
|