External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-05-07 01:17:37 -02:30
Code Issues Packages Projects Releases Wiki Activity

Prevent inventory updates started via projects from running on controlplane

Browse Source
This commit is contained in:
Shane McDonald
2021-06-23 12:11:07 -04:00
parent 057bd6e625
commit 2fa27000ab
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
awx/main/tasks.py
View File

@@ -2072,12 +2072,20 @@ class RunProjectUpdate(BaseTask):
if InventoryUpdate.objects.filter(inventory_source=inv_src, status__in=ACTIVE_STATES).exists(): if InventoryUpdate.objects.filter(inventory_source=inv_src, status__in=ACTIVE_STATES).exists():
logger.debug('Skipping SCM inventory update for `{}` because ' 'another update is already active.'.format(inv_src.name)) logger.debug('Skipping SCM inventory update for `{}` because ' 'another update is already active.'.format(inv_src.name))
continue continue
if settings.IS_K8S:
instance_group = InventoryUpdate(inventory_source=inv_src).preferred_instance_groups[0]
execution_node = None
else:
instance_group = project_update.instance_group
execution_node = project_update.execution_node
local_inv_update = inv_src.create_inventory_update( local_inv_update = inv_src.create_inventory_update(
_eager_fields=dict( _eager_fields=dict(
launch_type='scm', launch_type='scm',
status='running', status='running',
instance_group=project_update.instance_group, instance_group=instance_group,
execution_node=project_update.execution_node, execution_node=execution_node,
source_project_update=project_update, source_project_update=project_update,
celery_task_id=project_update.celery_task_id, celery_task_id=project_update.celery_task_id,
) )