[BUG]: DFP integrated training Azure pipeline is broken

[yczhang-nv]

Version

24.10

Which installation method(s) does this occur on?

Docker

Describe the bug.

DFP integrated training pipelines inexamples/digital_fingerprinting/production/ yields an error with Azure source, which indicates that user_id is not attached to ControlMessage.

Minimum reproducible example

python dfp_integrated_training_batch_pipeline.py  --tracking_uri="http://localhost:5000/" \
        --log_level DEBUG \
        --use_cpp=true \
        --source azure \
        --silence_monitors \
        --start_time "2022-08-10" \
        --duration "60d" \
        --train_users generic \
        --input_file "./control_messages/azure_payload_training.json"

Relevant log output

Click here to see error details

Exception occurred in pipeline. Rethrowing
Traceback (most recent call last):
  File "/home/dagardner/work/m3/python/morpheus/morpheus/pipeline/pipeline.py", line 405, in post_start
    await executor.join_async()
  File "/home/dagardner/work/m3/python/morpheus/morpheus/controllers/mlflow_model_writer_controller.py", line 226, in on_data
    reg_model_name = self.user_id_to_model(user_id=user)
  File "/home/dagardner/work/m3/python/morpheus/morpheus/controllers/mlflow_model_writer_controller.py", line 126, in user_id_to_model
    "user_id": self._create_safe_user_id(user_id),
  File "/home/dagardner/work/m3/python/morpheus/morpheus/controllers/mlflow_model_writer_controller.py", line 104, in _create_safe_user_id
    safe_user_id = user_id.replace('.', '_dot_')
AttributeError: 'NoneType' object has no attribute 'replace'

Full env printout

Click here to see environment details

[Paste the results of print_env.sh here, it will be hidden by default]

Other/Misc.

No response

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