def METHOD_NAME(self):
    gx_req1 = ActivateFlowsRequest()
    gx_req2 = ActivateFlowsRequest()
    gy_req = ActivateFlowsRequest(
        request_origin=RequestOriginType(type=RequestOriginType.GY),
    )
    setup_req = SetupPolicyRequest(requests=[gx_req1, gx_req2, gy_req])
    self.pipelined_srv.SetupPolicyFlows(setup_req, MagicMock())
    self._enforcer_app.handle_restart.assert_called_with([gx_req1, gx_req2])
    self._enforcement_stats.handle_restart.assert_called_with([gx_req1, gx_req2])
    self._gy_app.handle_restart.assert_called_with([gy_req])