fetaure-rc/SIENTIAPDE-2164- fix: drop star-unpack guard on input_gate result, back to fixed 4-tuple
This commit is contained in:
@@ -134,22 +134,12 @@ class PredictionProcess:
|
|||||||
|
|
||||||
# `document` describes which filter(s) produced `path_flag` (`None` when nothing was
|
# `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.
|
# 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
|
path_flag, confidence, comment, document = await workflow.execute_local_activity_method(
|
||||||
# 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(
|
|
||||||
Activities.input_gate,
|
Activities.input_gate,
|
||||||
gate_input,
|
gate_input,
|
||||||
retry_policy=retry_policy,
|
retry_policy=retry_policy,
|
||||||
start_to_close_timeout=timedelta(minutes=1),
|
start_to_close_timeout=timedelta(minutes=1),
|
||||||
)
|
)
|
||||||
document = document_tail[0] if document_tail else None
|
|
||||||
|
|
||||||
# Handle path decision based on filter results
|
# Handle path decision based on filter results
|
||||||
if await self.path_flag_handler(
|
if await self.path_flag_handler(
|
||||||
|
|||||||
Reference in New Issue
Block a user