more

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)