def METHOD_NAME(self, topics: Set[str]) -> CopartitionedAssignment:
    assignment = CopartitionedAssignment(
        actives=self._colocated_partitions(topics, active=True),
        standbys=self._colocated_partitions(topics, active=False),
        topics=topics,
    )
    assignment.validate()
    return assignment