Log applied objects to MLflow ops experiment.
(
self,
objects: List[Any],
transition_types: Optional[Dict[str, str]] = None,
)
| 1641 | self._mlflow_log_apply(objects) |
| 1642 | |
| 1643 | def _mlflow_log_apply( |
| 1644 | self, |
| 1645 | objects: List[Any], |
| 1646 | transition_types: Optional[Dict[str, str]] = None, |
| 1647 | ): |
| 1648 | """Log applied objects to MLflow ops experiment.""" |
| 1649 | try: |
| 1650 | if self.mlflow is None or not self.config.mlflow.log_operations: |
| 1651 | return |
| 1652 | self.mlflow.log_apply( |
| 1653 | changed_objects=objects, |
| 1654 | transition_types=transition_types, |
| 1655 | ) |
| 1656 | except Exception as e: |
| 1657 | _logger.debug("MLflow apply logging failed: %s", e) |
| 1658 | |
| 1659 | def _emit_openlineage_apply(self, objects: List[Any]): |
| 1660 | """Emit OpenLineage events for applied objects.""" |
no test coverage detected