From f43467c2fdfe3057272010d4c4fc1913984eb025 Mon Sep 17 00:00:00 2001
From: Shuchang Zheng <wintonzheng0325@gmail.com>
Date: Wed, 1 Oct 2025 17:00:35 -0700
Subject: [PATCH] do not delete cache when running task v2 while workflow is
 being updated (#3586)

---
 skyvern/forge/sdk/workflow/service.py | 6 +++++-
 skyvern/services/task_v2_service.py   | 1 +
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/skyvern/forge/sdk/workflow/service.py b/skyvern/forge/sdk/workflow/service.py
index 07fc4886..dd0ee214 100644
--- a/skyvern/forge/sdk/workflow/service.py
+++ b/skyvern/forge/sdk/workflow/service.py
@@ -924,6 +924,7 @@ class WorkflowService:
         title: str | None = None,
         description: str | None = None,
         workflow_definition: WorkflowDefinition | None = None,
+        delete_script: bool = True,
     ) -> Workflow:
         if workflow_definition:
             workflow_definition.validate()
@@ -947,7 +948,8 @@ class WorkflowService:
 
         # Check if workflow definition changed and delete published workflow scripts if so
         if (
-            workflow_definition
+            delete_script
+            and workflow_definition
             and previous_workflow
             and organization_id
             and _get_workflow_definition_without_dates(previous_workflow.workflow_definition)
@@ -1849,6 +1851,7 @@ class WorkflowService:
         organization: Organization,
         request: WorkflowCreateYAMLRequest,
         workflow_permanent_id: str | None = None,
+        delete_script: bool = True,
     ) -> Workflow:
         organization_id = organization.organization_id
         LOG.info(
@@ -2094,6 +2097,7 @@ class WorkflowService:
                 workflow_id=workflow.workflow_id,
                 organization_id=organization_id,
                 workflow_definition=workflow_definition,
+                delete_script=delete_script,
             )
             LOG.info(
                 f"Created workflow from request, title: {request.title}",
diff --git a/skyvern/services/task_v2_service.py b/skyvern/services/task_v2_service.py
index 541cec40..f625004f 100644
--- a/skyvern/services/task_v2_service.py
+++ b/skyvern/services/task_v2_service.py
@@ -812,6 +812,7 @@ async def run_task_v2_helper(
             organization=organization,
             request=workflow_create_request,
             workflow_permanent_id=workflow.workflow_permanent_id,
+            delete_script=False,
         )
         LOG.info("Workflow created", workflow_id=workflow.workflow_id)