Skip to content

Instantly share code, notes, and snippets.

@WaylonWalker
Created May 23, 2020 20:22
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save WaylonWalker/b97fd496e838422644ed300212ea0c1f to your computer and use it in GitHub Desktop.
Save WaylonWalker/b97fd496e838422644ed300212ea0c1f to your computer and use it in GitHub Desktop.
from kedro.framework.hooks import hook_impl
class <hook_name>:
def __init__(self):
pass
@hook_impl
def before_pipeline_run(self, run_params, pipeline, catalog):
pass
@hook_impl
def after_pipeline_run(self, run_params, pipeline, catalog):
pass
@hook_impl
def on_pipeline_error(self, error, run_params, pipeline, catalog):
pass
@hook_impl
def after_catalog_created(
self,
catalog,
conf_catalog,
conf_creds,
feed_dict,
save_version,
load_versions,
run_id,
):
pass
@hook_impl
def before_node_run(self, node, catalog, inputs, is_async, run_id):
pass
@hook_impl
def after_node_run(self, node, catalog, inputs, outputs, is_async, run_id):
pass
@hook_impl
def on_node_error(self, error, node, catalog, inputs, is_async, run_id):
pass
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment