def compute_monitoring(feature_view_metadata: dict):
        """Compute monitoring metrics for newly obbserved data.

        Args:
            feature_view_metadata: metadata containing the version of the feature store feature view version.
        """

        from batch_prediction_pipeline import monitoring

        monitoring.compute(
            feature_view_version=feature_view_metadata["feature_view_version"],
        )
Compute monitoring metrics for newly obbserved data.

        Args:
            feature_view_metadata: metadata containing the version of the feature store feature view version.
        
airflow/dags/ml_pipeline_dag.py