From 32dfa8da6843c9f512a4b76d7071a833d6c3834d Mon Sep 17 00:00:00 2001
From: LawyZheng <lawyzheng1106@gmail.com>
Date: Wed, 27 Aug 2025 14:07:45 +0800
Subject: [PATCH] pass workflow pid when execute workflow (#3306)

---
 skyvern/forge/sdk/executor/async_executor.py | 2 ++
 skyvern/forge/sdk/routes/agent_protocol.py   | 1 +
 skyvern/services/block_service.py            | 2 ++
 skyvern/services/workflow_service.py         | 1 +
 4 files changed, 6 insertions(+)

diff --git a/skyvern/forge/sdk/executor/async_executor.py b/skyvern/forge/sdk/executor/async_executor.py
index 3745fdba..b1170cbd 100644
--- a/skyvern/forge/sdk/executor/async_executor.py
+++ b/skyvern/forge/sdk/executor/async_executor.py
@@ -42,6 +42,7 @@ class AsyncExecutor(abc.ABC):
         organization: Organization,
         workflow_id: str,
         workflow_run_id: str,
+        workflow_permanent_id: str,
         max_steps_override: int | None,
         api_key: str | None,
         browser_session_id: str | None,
@@ -145,6 +146,7 @@ class BackgroundTaskExecutor(AsyncExecutor):
         organization: Organization,
         workflow_id: str,
         workflow_run_id: str,
+        workflow_permanent_id: str,
         max_steps_override: int | None,
         api_key: str | None,
         browser_session_id: str | None,
diff --git a/skyvern/forge/sdk/routes/agent_protocol.py b/skyvern/forge/sdk/routes/agent_protocol.py
index 3261c2d1..1027d7ef 100644
--- a/skyvern/forge/sdk/routes/agent_protocol.py
+++ b/skyvern/forge/sdk/routes/agent_protocol.py
@@ -878,6 +878,7 @@ async def run_block(
         block_labels=block_run_request.block_labels,
         workflow_id=block_run_request.workflow_id,
         workflow_run_id=workflow_run.workflow_run_id,
+        workflow_permanent_id=workflow_run.workflow_permanent_id,
         organization=organization,
         browser_session_id=browser_session_id,
     )
diff --git a/skyvern/services/block_service.py b/skyvern/services/block_service.py
index dcf05c1d..18da5285 100644
--- a/skyvern/services/block_service.py
+++ b/skyvern/services/block_service.py
@@ -51,6 +51,7 @@ async def execute_blocks(
     block_labels: list[str],
     workflow_id: str,
     workflow_run_id: str,
+    workflow_permanent_id: str,
     organization: Organization,
     browser_session_id: str | None = None,
 ) -> None:
@@ -71,6 +72,7 @@ async def execute_blocks(
         organization=organization,
         workflow_id=workflow_id,
         workflow_run_id=workflow_run_id,
+        workflow_permanent_id=workflow_permanent_id,
         max_steps_override=None,
         browser_session_id=browser_session_id,
         api_key=api_key,
diff --git a/skyvern/services/workflow_service.py b/skyvern/services/workflow_service.py
index 807faac7..5fee060d 100644
--- a/skyvern/services/workflow_service.py
+++ b/skyvern/services/workflow_service.py
@@ -86,6 +86,7 @@ async def run_workflow(
         organization=organization,
         workflow_id=workflow_run.workflow_id,
         workflow_run_id=workflow_run.workflow_run_id,
+        workflow_permanent_id=workflow_run.workflow_permanent_id,
         max_steps_override=max_steps,
         browser_session_id=workflow_request.browser_session_id,
         api_key=api_key,