Skip to content

Commit c7bc593

Browse files
Removed the commented code
1 parent 9910f1e commit c7bc593

File tree

4 files changed

+0
-28
lines changed

4 files changed

+0
-28
lines changed

src/backend/v3/api/router.py

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -396,9 +396,6 @@ async def plan_approval(
396396
orchestration_config
397397
and human_feedback.m_plan_id in orchestration_config.approvals
398398
):
399-
# orchestration_config.approvals[human_feedback.m_plan_id] = (
400-
# human_feedback.approved
401-
# )
402399
orchestration_config.set_approval_result(
403400
human_feedback.m_plan_id, human_feedback.approved
404401
)
@@ -531,9 +528,6 @@ async def user_clarification(
531528
orchestration_config
532529
and human_feedback.request_id in orchestration_config.clarifications
533530
):
534-
# orchestration_config.clarifications[human_feedback.request_id] = (
535-
# human_feedback.answer
536-
# )
537531
# Use the new event-driven method to set clarification result
538532
orchestration_config.set_clarification_result(
539533
human_feedback.request_id, human_feedback.answer

src/backend/v3/magentic_agents/proxy_agent.py

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -270,17 +270,6 @@ async def invoke_stream(
270270
async def _wait_for_user_clarification(
271271
self, request_id: str
272272
) -> Optional[UserClarificationResponse]:
273-
# """Wait for user clarification response."""
274-
# # To do: implement timeout and error handling
275-
# if request_id not in orchestration_config.clarifications:
276-
# orchestration_config.clarifications[request_id] = None
277-
# while orchestration_config.clarifications[request_id] is None:
278-
# await asyncio.sleep(0.2)
279-
# return UserClarificationResponse(
280-
# request_id=request_id,
281-
# answer=orchestration_config.clarifications[request_id],
282-
# )
283-
284273
"""
285274
Wait for user clarification response using event-driven pattern with timeout handling.
286275

src/backend/v3/orchestration/human_approval_manager.py

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -206,16 +206,6 @@ async def create_progress_ledger(
206206
async def _wait_for_user_approval(
207207
self, m_plan_id: Optional[str] = None
208208
) -> Optional[messages.PlanApprovalResponse]:
209-
# """Wait for user approval response."""
210-
211-
# # To do: implement timeout and error handling
212-
# if m_plan_id not in orchestration_config.approvals:
213-
# orchestration_config.approvals[m_plan_id] = None
214-
# while orchestration_config.approvals[m_plan_id] is None:
215-
# await asyncio.sleep(0.2)
216-
# return messages.PlanApprovalResponse(
217-
# approved=orchestration_config.approvals[m_plan_id], m_plan_id=m_plan_id
218-
# )
219209
"""
220210
Wait for user approval response using event-driven pattern with timeout handling.
221211

src/backend/v3/orchestration/orchestration_manager.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,6 @@ async def run_orchestration(self, user_id, input_task) -> None:
119119
"""Run the orchestration with user input loop."""
120120

121121
job_id = str(uuid.uuid4())
122-
# orchestration_config.approvals[job_id] = None
123122

124123
# Use the new event-driven method to set approval as pending
125124
orchestration_config.set_approval_pending(job_id)

0 commit comments

Comments
 (0)