Remove unused MLflow client arg from DFP inference implementations

docs/source/developer_guide/guides/10_modular_pipeline_digital_fingerprinting.md

@@ -45,6 +45,12 @@ limitations under the License.
     - [DFP Post Processing](#dfp-post-processing)
     - [Serialize](#serialize)
     - [Write to File](#write-to-file)
+  - [Running Example Modular DFP Pipelines](#running-example-modular-dfp-pipelines)
+    - [System requirements](#system-requirements)
+    - [Building the services](#building-the-services)
+    - [Downloading the example datasets](#downloading-the-example-datasets)
+    - [Run Morpheus pipeline](#run-morpheus-pipeline)
+    - [Output Fields](#output-fields)
 
 ## Introduction
 
@@ -522,7 +528,7 @@ pip install s3fs
 python examples/digital_fingerprinting/fetch_example_data.py all
 ```
 
-### Morpheus Pipeline
+### Run Morpheus pipeline
 From the `examples/digital_fingerprinting/production` dir, run:
 ```bash
 docker compose run morpheus_pipeline bash

examples/digital_fingerprinting/production/morpheus/dfp/modules/dfp_inference.py

@@ -97,7 +97,7 @@ def process_task(control_message: ControlMessage):
             if (model_cache is None):
                 raise RuntimeError(f"Could not find model for user {user_id}")
 
-            loaded_model = model_cache.load_model(client)
+            loaded_model = model_cache.load_model()
 
         # TODO(Devin): Recovery strategy should be more robust/configurable in practice
         except Exception as exec_info:

examples/digital_fingerprinting/production/morpheus/dfp/stages/dfp_inference_stage.py

@@ -98,7 +98,7 @@ def on_data(self, message: MultiDFPMessage) -> MultiDFPMessage:
             if (model_cache is None):
                 raise RuntimeError(f"Could not find model for user {user_id}")
 
-            loaded_model = model_cache.load_model(self._client)
+            loaded_model = model_cache.load_model()
 
         except Exception:
             logger.exception("Error trying to get model", exc_info=True)

examples/digital_fingerprinting/production/morpheus/dfp/utils/model_cache.py

@@ -92,7 +92,7 @@ def last_used(self):
     def last_checked(self):
         return self._last_checked
 
-    def load_model(self, _) -> AutoEncoder:
+    def load_model(self) -> AutoEncoder:
 
         now = datetime.now()