using Pipe instead of second queue; added consumer count; updated method...
using Pipe instead of second queue; added consumer count; updated method names; updated process_pipe method; updated logging
Showing
- .env 1 addition, 1 deletion.env
- .gitignore 1 addition, 0 deletions.gitignore
- cryton_worker/cli.py 9 additions, 6 deletionscryton_worker/cli.py
- cryton_worker/etc/config.py 1 addition, 2 deletionscryton_worker/etc/config.py
- cryton_worker/lib/event.py 14 additions, 36 deletionscryton_worker/lib/event.py
- cryton_worker/lib/util.py 28 additions, 39 deletionscryton_worker/lib/util.py
- cryton_worker/lib/worker.py 273 additions, 177 deletionscryton_worker/lib/worker.py
- tests/unit_tests/test_cli.py 2 additions, 1 deletiontests/unit_tests/test_cli.py
- tests/unit_tests/test_event.py 13 additions, 43 deletionstests/unit_tests/test_event.py
- tests/unit_tests/test_util.py 8 additions, 26 deletionstests/unit_tests/test_util.py
- tests/unit_tests/test_worker.py 202 additions, 153 deletionstests/unit_tests/test_worker.py
Loading
Please register or sign in to comment