diff --git a/core/src/main/java/com/netflix/conductor/core/execution/tasks/IsolatedTaskQueueProducer.java b/core/src/main/java/com/netflix/conductor/core/execution/tasks/IsolatedTaskQueueProducer.java index ce4477c5cd..46dab7916a 100644 --- a/core/src/main/java/com/netflix/conductor/core/execution/tasks/IsolatedTaskQueueProducer.java +++ b/core/src/main/java/com/netflix/conductor/core/execution/tasks/IsolatedTaskQueueProducer.java @@ -79,7 +79,7 @@ void addTaskQueues() { for (TaskDef isolatedTaskDef : isolationTaskDefs) { for (String taskType : taskTypes) { String taskQueue = QueueUtils.getQueueName(taskType, null, - isolatedTaskDef.getExecutionNameSpace(), isolatedTaskDef.getIsolationGroupId()); + isolatedTaskDef.getIsolationGroupId(), isolatedTaskDef.getExecutionNameSpace()); logger.debug("Adding taskQueue:'{}' to system task worker coordinator", taskQueue); SystemTaskWorkerCoordinator.queue.add(taskQueue); }