Merge pull request #21980 from mvdbeek/fix_recording_parameter_way_too_often

[25.1] Fix recording duplicate workflow_request_input_step_parameter rows
This commit is contained in:
Nicola Soranzo
2026-03-03 23:41:18 +00:00
committed by GitHub
2 changed files with 4 additions and 1 deletions
+3
View File
@@ -9902,6 +9902,9 @@ class WorkflowInvocation(Base, UsesCreateAndUpdateTime, Dictifiable, Serializabl
for content in self.input_dataset_collections:
if content.workflow_step_id == step_id:
return True
for content in self.input_step_parameters:
if content.workflow_step_id == step_id:
return True
return False
def set_handler(self, handler):
+1 -1
View File
@@ -631,7 +631,7 @@ class WorkflowProgress:
if not invocation.has_input_for_step(step.id):
content = outputs.get("output", NO_REPLACEMENT)
if content is not NO_REPLACEMENT:
log.info("ADDING INPUT FOR STEP %s: %s", step.id, content, exc_info=True)
log.debug("Adding input for step %s: %s", step.id, content)
invocation.add_input(content, step.id)
self.set_step_outputs(invocation_step, outputs, already_persisted=already_persisted)