Skip to content

Commit

Permalink
refactor: Add error message with existing provenance when task prefix…
Browse files Browse the repository at this point in the history
… is missing
  • Loading branch information
provos committed Sep 12, 2024
1 parent 1c3850d commit cc2dd8d
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion src/planai/joined_task.py
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,8 @@ def consume_work(self, task: Task):
prefix = task.prefix_for_input_task(self.join_type)
if prefix is None:
raise ValueError(
f"Task {task} does not have a prefix for {self.join_type.__name__} in provenance."
f"Task {task} does not have a prefix for {self.join_type.__name__} in provenance. "
f"Existing provenance: {task._provenance}"
)
need_watch = False
with self._lock:
Expand Down

0 comments on commit cc2dd8d

Please sign in to comment.