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

fix get_workflow_for_workflow_run query; filter on wr org, not wf org (#3963)

Browse Source
This commit is contained in:
Jonathan Dobson
2025-11-11 12:44:17 -05:00
committed by GitHub
parent 37fa441463
commit 887a8a9b64
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
skyvern/forge/sdk/db/client.py
View File

@@ -1527,14 +1527,15 @@ class AgentDB:
if exclude_deleted: if exclude_deleted:
get_workflow_query = get_workflow_query.filter(WorkflowModel.deleted_at.is_(None)) get_workflow_query = get_workflow_query.filter(WorkflowModel.deleted_at.is_(None))
if organization_id:
get_workflow_query = get_workflow_query.filter_by(organization_id=organization_id)
get_workflow_query = get_workflow_query.join( get_workflow_query = get_workflow_query.join(
WorkflowRunModel, WorkflowRunModel,
WorkflowRunModel.workflow_id == WorkflowModel.workflow_id, WorkflowRunModel.workflow_id == WorkflowModel.workflow_id,
) )
if organization_id:
get_workflow_query = get_workflow_query.filter(WorkflowRunModel.organization_id == organization_id)
get_workflow_query = get_workflow_query.filter(WorkflowRunModel.workflow_run_id == workflow_run_id) get_workflow_query = get_workflow_query.filter(WorkflowRunModel.workflow_run_id == workflow_run_id)
async with self.Session() as session: async with self.Session() as session:
if workflow := (await session.scalars(get_workflow_query)).first(): if workflow := (await session.scalars(get_workflow_query)).first():