Emit OpenLineage events for applied objects.
(self, objects: List[Any])
| 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.""" |
| 1661 | if self.openlineage_emitter is None: |
| 1662 | return |
| 1663 | try: |
| 1664 | self.openlineage_emitter.emit_apply(objects, self.project) |
| 1665 | except Exception as e: |
| 1666 | warnings.warn(f"Failed to emit OpenLineage apply events: {e}") |
| 1667 | |
| 1668 | def teardown(self): |
| 1669 | """Tears down all local and cloud resources for the feature store.""" |
no test coverage detected