pass workflow pid when execute workflow (#3306)

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,

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,
     )

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,

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,