diff --git a/laborious/workflows/sub_workflows/prediction_process.py b/laborious/workflows/sub_workflows/prediction_process.py index e8c3064..aba6006 100644 --- a/laborious/workflows/sub_workflows/prediction_process.py +++ b/laborious/workflows/sub_workflows/prediction_process.py @@ -134,22 +134,12 @@ class PredictionProcess: # `document` describes which filter(s) produced `path_flag` (`None` when nothing was # filtered); `path_flag_handler` is the one that decides whether and how to persist it. - # Star-unpack rather than a fixed 4-tuple: `input_gate` is a local activity, so its result - # is recorded in workflow history; an execution already in flight when this field was - # added would replay a 3-element result here, and exact unpacking would raise ValueError - # on replay (review finding, 2026-09-30). - ( - path_flag, - confidence, - comment, - *document_tail, - ) = await workflow.execute_local_activity_method( + path_flag, confidence, comment, document = await workflow.execute_local_activity_method( Activities.input_gate, gate_input, retry_policy=retry_policy, start_to_close_timeout=timedelta(minutes=1), ) - document = document_tail[0] if document_tail else None # Handle path decision based on filter results if await self.path_flag_handler(