hooks.py

python
class PanderaCheckHooks:
    from kedro.pipeline.node import Node
    from kedro.io.data_catalog import DataCatalog

    @hook_impl
    def on_node_error(
        error: Exception,
        node: Node,
        catalog: DataCatalog,
        inputs: Dict[str, Any],
        is_async: bool,
        run_id: str,
    ):
        pass # do something