diff --git a/dagrunner/execute_graph.py b/dagrunner/execute_graph.py index 8219d84..0ce4c38 100755 --- a/dagrunner/execute_graph.py +++ b/dagrunner/execute_graph.py @@ -130,7 +130,9 @@ def plugin_executor( arg for arg in args if arg is not None ] # support plugins that have no return value if call is None: - raise ValueError("call is a required argument") + raise ValueError( + f"call is a required argument\nnode_properties: {node_properties}" + ) if verbose: print(f"args: {args}") print(f"call: {call}") @@ -162,7 +164,7 @@ def plugin_executor( else: raise ValueError( f"expecting 1, 2 or 3 values to unpack for {callable_obj}, " - f"got {len(call)}" + f"got {len(call)}\nnode_properties: {node_properties}" ) callable_kwargs_init = ( {} if callable_kwargs_init is None else callable_kwargs_init @@ -175,7 +177,7 @@ def plugin_executor( else: raise ValueError( f"expecting 1 or 2 values to unpack for {callable_obj}, got " - f"{len(call)}" + f"{len(call)}\nnode_properties: {node_properties}" ) callable_kwargs = {} if callable_kwargs is None else callable_kwargs @@ -191,7 +193,10 @@ def plugin_executor( try: callable_obj = callable_obj(**callable_kwargs_init) except Exception as err: - msg = f"Failed to initialise {obj_name} with {callable_kwargs_init}" + msg = ( + f"Failed to initialise {obj_name} with {callable_kwargs_init}" + f"\nnode_properties: {node_properties}" + ) raise RuntimeError(msg) from err call_msg = f"(**{callable_kwargs_init})" @@ -210,7 +215,10 @@ def plugin_executor( try: res = callable_obj(*args, **callable_kwargs) except Exception as err: - msg = f"Failed to execute {obj_name} with {args}, {callable_kwargs}" + msg = ( + f"Failed to execute {obj_name} with {args}, {callable_kwargs}" + f"\nnode_properties: {node_properties}" + ) raise RuntimeError(msg) from err msg = f"{str(timer)}; {msg}; {mem.max()}" logging.info(msg)