void createPendingTasks(final Set<String> currentNamedTopologies) {
        final Map<TaskId, Set<TopicPartition>> activeTasksToCreate = tasks.drainPendingActiveTasksForTopologies(currentNamedTopologies);
        final Map<TaskId, Set<TopicPartition>> standbyTasksToCreate = tasks.drainPendingStandbyTasksForTopologies(currentNamedTopologies);

        createNewTasks(activeTasksToCreate, standbyTasksToCreate);
    }
Handle any added or removed NamedTopologies. Check if any uncreated assigned tasks belong to a newly
added NamedTopology and create them if so, then close any tasks whose named topology no longer exists
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java