@modifies
    @collective
    def zero_rows(self, rows, diag_val=1.0):
        base._trace.evaluate(set([self]), set([self]))
        self._assemble()
        rows = rows.indices if isinstance(rows, Subset) else rows
        self.handle.zeroRowsLocal(rows, diag_val)
Break the connection between a service's queue consumer and rabbit
dataset/ETHPy150Open OP2/PyOP2/pyop2/petsc_base.py/Mat.zero_rows--crossover with--dataset/ETHPy150Open onefinestay/nameko/test/test_broker.py/test_service_disconnect_with_active_rpc_worker_via_service_proxy