vodorod/Dorod-Sky
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Exclude model field from cache invalidation comparison (SKY-7016) (#4526)

Browse Source
This commit is contained in:
pedrohsdb
2026-01-22 17:22:26 -08:00
committed by GitHub
parent db8ebac4a0
commit 1f16192915
1 changed files with 23 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
skyvern/forge/sdk/workflow/service.py
View File

@@ -177,6 +177,7 @@ def _get_workflow_definition_core_data(workflow_definition: WorkflowDefinition)
"disable_cache", "disable_cache",
"next_block_label", "next_block_label",
"version", "version",
"model",
] ]
# Use BFS to recursively remove fields from all nested objects # Use BFS to recursively remove fields from all nested objects
@@ -1971,6 +1972,28 @@ class WorkflowService:
current_definition = _get_workflow_definition_core_data(previous_valid_workflow.workflow_definition) current_definition = _get_workflow_definition_core_data(previous_valid_workflow.workflow_definition)
new_definition = _get_workflow_definition_core_data(workflow_definition) new_definition = _get_workflow_definition_core_data(workflow_definition)
has_changes = current_definition != new_definition has_changes = current_definition != new_definition
# Log definition changes for debugging cache invalidation issues (SKY-7016)
if has_changes:
LOG.debug(
"Workflow definition has changes, checking for cache invalidation",
workflow_id=workflow.workflow_id,
workflow_permanent_id=workflow.workflow_permanent_id,
organization_id=organization_id,
previous_version=previous_valid_workflow.version,
new_version=workflow.version,
current_block_count=len(current_definition.get("blocks", [])),
new_block_count=len(new_definition.get("blocks", [])),
current_param_count=len(current_definition.get("parameters", [])),
new_param_count=len(new_definition.get("parameters", [])),
)
else:
LOG.debug(
"Workflow definition unchanged, skipping cache invalidation check",
workflow_id=workflow.workflow_id,
workflow_permanent_id=workflow.workflow_permanent_id,
organization_id=organization_id,
)
else: else:
has_changes = False has_changes = False