mirror of
https://github.com/ansible/awx.git
synced 2026-06-22 15:17:44 -02:30
d5e5ea3670
Move plugin loading to lazy-on-first-access, DB sync to dispatcher Remove credential type and inventory plugin loading from Django's app.ready() path. In-memory registries (ManagedCredentialType.registry and InventorySourceOptions.injectors) are now populated lazily on first access via LazyLoadDict, a dict subclass that calls a loader function on the first read operation. This ensures web workers, dispatcher workers, and management commands all get the registries populated exactly when needed, without eager loading at startup. The DB sync (CredentialType.setup_tower_managed_defaults) is moved to the dispatcher's startup task, where it only needs to run once per deployment rather than in every Django process. Co-Authored-By: Alan Rominger <arominge@redhat.com> Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
72 lines
2.5 KiB
Python
72 lines
2.5 KiB
Python
from dispatcherd.config import setup as dispatcher_setup
|
|
|
|
from django.apps import AppConfig
|
|
from django.db import connection
|
|
from django.utils.translation import gettext_lazy as _
|
|
from django.core.management.base import CommandError
|
|
from django.db.models.signals import pre_migrate
|
|
|
|
from awx.main.utils.named_url_graph import _customize_graph, generate_graph
|
|
from awx.main.utils.db import db_requirement_violations
|
|
from awx.conf import register, fields
|
|
|
|
|
|
class MainConfig(AppConfig):
|
|
name = 'awx.main'
|
|
verbose_name = _('Main')
|
|
|
|
def check_db_requirement(self, *args, **kwargs):
|
|
violations = db_requirement_violations()
|
|
if violations:
|
|
raise CommandError(violations)
|
|
|
|
def load_named_url_feature(self):
|
|
models = [m for m in self.get_models() if hasattr(m, 'get_absolute_url')]
|
|
generate_graph(models)
|
|
_customize_graph()
|
|
register(
|
|
'NAMED_URL_FORMATS',
|
|
field_class=fields.DictField,
|
|
read_only=True,
|
|
label=_('Formats of all available named urls'),
|
|
help_text=_('Read-only list of key-value pairs that shows the standard format of all available named URLs.'),
|
|
category=_('Named URL'),
|
|
category_slug='named-url',
|
|
)
|
|
register(
|
|
'NAMED_URL_GRAPH_NODES',
|
|
field_class=fields.DictField,
|
|
read_only=True,
|
|
label=_('List of all named url graph nodes.'),
|
|
help_text=_(
|
|
'Read-only list of key-value pairs that exposes named URL graph topology.'
|
|
' Use this list to programmatically generate named URLs for resources'
|
|
),
|
|
category=_('Named URL'),
|
|
category_slug='named-url',
|
|
)
|
|
|
|
def configure_dispatcherd(self):
|
|
"""This implements the default configuration for dispatcherd
|
|
|
|
If running the tasking service like awx-manage dispatcherd,
|
|
some additional config will be applied on top of this.
|
|
This configuration provides the minimum such that code can submit
|
|
tasks to pg_notify to run those tasks.
|
|
"""
|
|
from awx.main.dispatch.config import get_dispatcherd_config
|
|
|
|
if connection.vendor != 'postgresql':
|
|
config_dict = get_dispatcherd_config(mock_publish=True)
|
|
else:
|
|
config_dict = get_dispatcherd_config()
|
|
|
|
dispatcher_setup(config_dict)
|
|
|
|
def ready(self):
|
|
super().ready()
|
|
|
|
self.configure_dispatcherd()
|
|
self.load_named_url_feature()
|
|
pre_migrate.connect(self.check_db_requirement, sender=self)
|