diff --git a/awx/main/scheduler/task_manager.py b/awx/main/scheduler/task_manager.py index 37ee3c3fa6..39776ddd3f 100644 --- a/awx/main/scheduler/task_manager.py +++ b/awx/main/scheduler/task_manager.py @@ -262,7 +262,10 @@ class TaskManager: return # Before task leaves pending state, ensure that job_event partitions exist - create_partition() + # TODO: Currently, only creating partition for jobs. Drop contiditional once + # there are partitions for all job event types + if task_actual['type'] == 'job': + create_partition() task.status = 'waiting' (start_status, opts) = task.pre_start()