Nandita Koppisetty

# Summary What change needs making? Change in Kafka client to make it resilient to broker outages. # Use Cases When would you use this? When a Kafka broker experiences...

Currently, Numaflow watermarks is disabled for the pipeline. Enable it and test the pipeline end to end.

When publishing the unified anomaly score, we wait for all the metrics for a given timestamp and compute the unified anomaly score. If any of the metrics is not received,...

currently, resume training is only implemented for Argo Rollouts metrics, we need to implement the same for ArgoCD metrics trainer.

Add pipeline id to the ML metrics

2

ML metrics would now require pipeline id as per the latest config changes