External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-07-12 00:44:36 -02:30
Code Issues Packages Projects Releases Wiki Activity

Make dispatcherd min_workers literally 4 (#16421)

Browse Source 
assisted-by: claude
This commit is contained in:
Alan Rominger
2026-05-28 09:58:13 -04:00
committed by GitHub
parent e4fa4810eb
commit 9b922f70ed
3 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
awx/main/dispatch/config.py
View File

@@ -25,7 +25,7 @@ def get_dispatcherd_config(for_service: bool = False, mock_publish: bool = False
"version": 2, "version": 2,
"service": { "service": {
"pool_kwargs": { "pool_kwargs": {
"min_workers": settings.JOB_EVENT_WORKERS, "min_workers": settings.DISPATCHER_MIN_WORKERS,
"max_workers": max_workers, "max_workers": max_workers,
# This must be less than max_workers to make sense, which is usually 4 # This must be less than max_workers to make sense, which is usually 4
# With reserve of 1, after a burst of tasks, load needs to down to 4-1=3 # With reserve of 1, after a burst of tasks, load needs to down to 4-1=3

2
awx/main/tests/functional/management/test_dispatcherd.py
View File

@@ -8,7 +8,7 @@ from awx.main.management.commands.dispatcherd import _hash_config
def test_dispatcherd_config_hash_is_stable(settings, monkeypatch): def test_dispatcherd_config_hash_is_stable(settings, monkeypatch):
monkeypatch.setenv('AWX_COMPONENT', 'dispatcher') monkeypatch.setenv('AWX_COMPONENT', 'dispatcher')
settings.CLUSTER_HOST_ID = 'test-node' settings.CLUSTER_HOST_ID = 'test-node'
settings.JOB_EVENT_WORKERS = 1 settings.DISPATCHER_MIN_WORKERS = 1
settings.DISPATCHER_SCHEDULE = {} settings.DISPATCHER_SCHEDULE = {}
config_one = get_dispatcherd_config(for_service=True) config_one = get_dispatcherd_config(for_service=True)

3
awx/settings/defaults.py
View File

@@ -215,6 +215,9 @@ LOCAL_STDOUT_EXPIRE_TIME = 2592000
# events into the database # events into the database
JOB_EVENT_WORKERS = 4 JOB_EVENT_WORKERS = 4
# Minimum number of workers for the dispatcher (dispatcherd) process pool
DISPATCHER_MIN_WORKERS = 4
# The number of seconds to buffer callback receiver bulk # The number of seconds to buffer callback receiver bulk
# writes in memory before flushing via JobEvent.objects.bulk_create() # writes in memory before flushing via JobEvent.objects.bulk_create()
JOB_EVENT_BUFFER_SECONDS = 1 JOB_EVENT_BUFFER_SECONDS = 1