Erwin
11/15/2023, 6:42 PM_suggest_resume_scenario
for the resume scenario optional? I’ve been experiencing consistent failures in my pipelines, and while I’m attempting to gather errors with the hook on_pipeline_error, I’ve noticed that this function tends to clutter my log due to its frequent failures in suggesting something.
So, the final expection is always due to _suggest_resume_scenario
and not about the most relevant thing: the actual error.Deepyaman Datta
11/15/2023, 6:52 PMErwin
11/15/2023, 6:57 PMsequential_runner
commenting this part to raise the original expection and not the one originated in
self._suggest_resume_scenario(pipeline, done_nodes, catalog)
for exec_index, node in enumerate(nodes):
try:
run_node(node, catalog, hook_manager, self._is_async, session_id)
done_nodes.add(node)
except Exception:
#self._suggest_resume_scenario(pipeline, done_nodes, catalog)
raise
Nok Lam Chan
11/16/2023, 2:44 AM