Skip to content

Commit ce43826

Browse files
committed
fix coverage
1 parent c63e2bf commit ce43826

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

tests/test_dbos.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1201,11 +1201,12 @@ async def hitl_main_loop(prompt: str) -> AgentRunResult[str | DeferredToolReques
12011201
if status.status == 'SUCCESS':
12021202
break
12031203

1204+
assert status.status == 'PENDING'
12041205
# Wait and check if the workflow has set a deferred tool request event.
12051206
deferred_tool_requests = await DBOS.get_event_async(
12061207
wf_handle.workflow_id, 'deferred_tool_requests', timeout_seconds=1
12071208
)
1208-
if deferred_tool_requests is not None:
1209+
if deferred_tool_requests is not None: # pragma: no branch
12091210
results = DeferredToolResults()
12101211
# Approve all calls
12111212
for tool_call in deferred_tool_requests.approvals:
@@ -1328,7 +1329,7 @@ def hitl_main_loop_sync(prompt: str) -> AgentRunResult[str | DeferredToolRequest
13281329

13291330
# Wait and check if the workflow has set a deferred tool request event.
13301331
deferred_tool_requests = DBOS.get_event(wf_handle.workflow_id, 'deferred_tool_requests', timeout_seconds=1)
1331-
if deferred_tool_requests is not None:
1332+
if deferred_tool_requests is not None: # pragma: no branch
13321333
results = DeferredToolResults()
13331334
# Approve all calls
13341335
for tool_call in deferred_tool_requests.approvals:

0 commit comments

Comments
 (0)