External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-03-10 14:09:28 -02:30
Code Issues Packages Projects Releases Wiki Activity

reap k8s-based jobs when the dispatcher restarts

Browse Source
This commit is contained in:
Ryan Petrello
2019-10-21 11:18:44 -04:00
parent 5bb7e69a4d
commit 812d00f490
1 changed files with 16 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
awx/main/scheduler/task_manager.py
View File

@@ -252,19 +252,25 @@ class TaskManager():
logger.debug('Submitting isolated {} to queue {} controlled by {}.'.format( logger.debug('Submitting isolated {} to queue {} controlled by {}.'.format(
task.log_format, task.execution_node, controller_node)) task.log_format, task.execution_node, controller_node))
elif rampart_group.is_containerized: elif rampart_group.is_containerized:
# find one real, non-containerized instance with capacity to
# act as the controller for k8s API interaction
match = None
for group in InstanceGroup.objects.all():
if group.is_containerized or group.controller_id:
continue
match = group.find_largest_idle_instance()
if match:
break
task.instance_group = rampart_group task.instance_group = rampart_group
if not task.supports_isolation(): if task.supports_isolation():
task.controller_node = match.hostname
else:
# project updates and inventory updates don't *actually* run in pods, # project updates and inventory updates don't *actually* run in pods,
# so just pick *any* non-isolated, non-containerized host and use it # so just pick *any* non-isolated, non-containerized host and use it
for group in InstanceGroup.objects.all(): # as the execution node
if group.is_containerized or group.controller_id: task.execution_node = match.hostname
continue logger.debug('Submitting containerized {} to queue {}.'.format(
match = group.find_largest_idle_instance() task.log_format, task.execution_node))
if match:
task.execution_node = match.hostname
logger.debug('Submitting containerized {} to queue {}.'.format(
task.log_format, task.execution_node))
break
else: else:
task.instance_group = rampart_group task.instance_group = rampart_group
if instance is not None: if instance is not None: