[BUG]: Error running example modular DFP pipelines

[efajardo-nv]

Version

24.03

Which installation method(s) does this occur on?

Docker

Describe the bug.

Getting error running any of the modular DFP examples.

Minimum reproducible example

No response

Relevant log output

Traceback (most recent call last):
  File "/workspace/examples/digital_fingerprinting/production/morpheus/dfp_integrated_training_batch_pipeline.py", line 276, in <module>
    run_pipeline(obj={}, auto_envvar_prefix='DFP', show_default=True, prog_name="dfp")
  File "/opt/conda/envs/morpheus/lib/python3.10/site-packages/click/core.py", line 1157, in __call__
    return self.main(*args, **kwargs)
  File "/opt/conda/envs/morpheus/lib/python3.10/site-packages/click/core.py", line 1078, in main
    rv = self.invoke(ctx)
  File "/opt/conda/envs/morpheus/lib/python3.10/site-packages/click/core.py", line 1434, in invoke
    return ctx.invoke(self.callback, **ctx.params)
  File "/opt/conda/envs/morpheus/lib/python3.10/site-packages/click/core.py", line 783, in invoke
    return __callback(*args, **kwargs)
  File "/workspace/examples/digital_fingerprinting/production/morpheus/dfp_integrated_training_batch_pipeline.py", line 272, in run_pipeline
    pipeline.run()
  File "/opt/conda/envs/morpheus/lib/python3.10/site-packages/morpheus/pipeline/pipeline.py", line 636, in run
    asyncio.run(self.run_async())
  File "/opt/conda/envs/morpheus/lib/python3.10/asyncio/runners.py", line 44, in run
    return loop.run_until_complete(main)
  File "/opt/conda/envs/morpheus/lib/python3.10/asyncio/base_events.py", line 649, in run_until_complete
    return future.result()
  File "/opt/conda/envs/morpheus/lib/python3.10/site-packages/morpheus/pipeline/pipeline.py", line 614, in run_async
    await self.join()
  File "/opt/conda/envs/morpheus/lib/python3.10/site-packages/morpheus/pipeline/pipeline.py", line 375, in join
    await self._mrc_executor.join_async()
  File "/opt/conda/envs/morpheus/lib/python3.10/site-packages/morpheus/controllers/mlflow_model_writer_controller.py", line 226, in on_data
    reg_model_name = self.user_id_to_model(user_id=user)
  File "/opt/conda/envs/morpheus/lib/python3.10/site-packages/morpheus/controllers/mlflow_model_writer_controller.py", line 130, in user_id_to_model
    return self._model_name_formatter.format(**kwargs)
KeyError: 'source'

Code of Conduct

• I agree to follow Morpheus' Code of Conduct
• I have searched the open bugs and have found no duplicates for this bug report