Add test

Author: nikita-savelyevv

src/nncf/data/dataset.py

@@ -38,6 +38,10 @@ class Dataset:
         will be passed into the model as-is.
     """
 
+    # RESET_STATE_KEY is a special input key used by OpenVINO backend to control resetting of internal model state
+    # between model inferences. This key can be added to a dataset sample input dictionary with either
+    # `True` or `False` value. With `True` value, the model state will be reset before inference on the corresponding
+    # sample, and with `False` the state will not be reset.
     RESET_STATE_KEY = "reset_state"
 
     def __init__(self, data_source: Iterable[Any], transform_func: Optional[Callable[..., Any]] = None):

src/nncf/openvino/engine.py

@@ -45,9 +45,14 @@ def infer(
         :return output_data: Model's output.
         """
         if isinstance(input_data, dict) and nncf.Dataset.RESET_STATE_KEY in input_data:
+            # In this case state resetting is controlled by the input data flag
             input_data = input_data.copy()
             if input_data.pop(nncf.Dataset.RESET_STATE_KEY):
-                self.infer_request.reset_state()
+                if self.reset_state:
+                    self.infer_request.reset_state()
+                else:
+                    msg = "Cannot reset state of a stateless model."
+                    raise RuntimeError(msg)
         elif self.reset_state:
             self.infer_request.reset_state()
 

tests/openvino/native/test_engine.py

@@ -8,10 +8,12 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
+from functools import wraps
 
 import numpy as np
 import pytest
 
+import nncf
 from nncf.openvino.engine import OVNativeEngine
 from tests.openvino.native.models import ConvModel
 from tests.openvino.native.models import LinearModel
@@ -77,3 +79,47 @@ def test_compiled_model_engine_inference_stateful(stateful):
     out = out["Result"]
 
     assert np.array_equal(out[0], input_data[0])
+
+
+def test_stateful_model_inference_with_controlled_resetting():
+    def wrap_reset_state(infer_request):
+        nonlocal reset_order
+        original_reset_state = infer_request.reset_state
+
+        @wraps(infer_request.reset_state)
+        def _reset_state():
+            reset_order.append("reset")
+            original_reset_state()
+
+        infer_request.reset_state = _reset_state
+
+    model = StatefulModel(True).ov_model
+    inp = model.get_parameters()[0]
+    input_data = [{"input_data": np.ones(inp.shape), nncf.Dataset.RESET_STATE_KEY: False} for _ in range(10)]
+    reset_ind = [2, 5, 7]
+    for ind in reset_ind:
+        input_data[ind][nncf.Dataset.RESET_STATE_KEY] = True
+
+    engine = OVNativeEngine(model)
+    reset_order = []
+    wrap_reset_state(engine.engine.infer_request)
+
+    for inp_data in input_data:
+        engine.infer(inp_data)
+        reset_order.append("infer")
+
+    assert reset_order == [
+        "infer",
+        "infer",
+        "reset",
+        "infer",
+        "infer",
+        "infer",
+        "reset",
+        "infer",
+        "infer",
+        "reset",
+        "infer",
+        "infer",
+        "infer",
+    ]