Skip to content

Commit 00a5a93

Browse files
committed
enh(plan): include jetsam when missing inputs
1 parent fbc8d85 commit 00a5a93

File tree

1 file changed

+9
-9
lines changed

1 file changed

+9
-9
lines changed

graphtik/network.py

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -415,16 +415,16 @@ def execute(self, named_inputs, overwrites=None, method=None):
415415
416416
*Plan needs more inputs...*
417417
"""
418-
# Check plan<-->inputs mismatch.
419-
#
420-
missing = iset(self.needs) - iset(named_inputs)
421-
if missing:
422-
raise ValueError(
423-
f"Plan needs more inputs: {list(missing)}"
424-
f"\n given inputs: {list(named_inputs)}\n {self}"
425-
)
426-
427418
try:
419+
# Check plan<-->inputs mismatch.
420+
#
421+
missing = iset(self.needs) - iset(named_inputs)
422+
if missing:
423+
raise ValueError(
424+
f"Plan needs more inputs: {list(missing)}"
425+
f"\n given inputs: {list(named_inputs)}\n {self}"
426+
)
427+
428428
# choose a method of execution
429429
executor = (
430430
self._execute_thread_pool_barrier_method

0 commit comments

Comments
 (0)