code: def _elect_source_replication_group(
              self,
              over_replicated_rgs,
              partition,
      ):
          
          return max(
              over_replicated_rgs,
              key=lambda rg: rg.count_replica(partition),
          )
docs: Decide source replication-group based as group with highest replica
          count.