From 4060eb201b0f66fe0491b13f4a36a94c6ac64ec8 Mon Sep 17 00:00:00 2001
From: SWangHash <88996709+SWangHash@users.noreply.github.com>
Date: Thu, 30 Jul 2026 17:51:25 +0800
Subject: [PATCH] fix(ohos): use tauri::async_runtime::spawn in scheduler to
 fix stuck second-round turn

The desktop entry pub fn run() creates a local tokio runtime that gets dropped after _run() returns on OHOS, which cancels all 	okio::spawn tasks including 
un_outcome_handler. Once the outcome receiver is dropped, the channel becomes closed so the coordinator cannot notify the scheduler of turn completion. The scheduler then keeps a stale ctive_turns entry, forcing subsequent submits into the queue forever.

Switching scheduler spawns to 	auri::async_runtime::spawn keeps them on Tauri's long-lived runtime.
---
 .../core/src/agentic/coordination/scheduler.rs       | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/src/crates/assembly/core/src/agentic/coordination/scheduler.rs b/src/crates/assembly/core/src/agentic/coordination/scheduler.rs
index 3a53511aab..cf343c7924 100644
--- a/src/crates/assembly/core/src/agentic/coordination/scheduler.rs
+++ b/src/crates/assembly/core/src/agentic/coordination/scheduler.rs
@@ -400,7 +400,7 @@ impl DialogScheduler {
         });
 
         let scheduler_for_handler = Arc::clone(&scheduler);
-        tokio::spawn(async move {
+         tauri::async_runtime::spawn(async move {
             scheduler_for_handler.run_outcome_handler(outcome_rx).await;
         });
 
@@ -1374,7 +1374,7 @@ impl DialogScheduler {
                 }
                 QueuedTurnExecution::HiddenSubagent(execution) => {
                     let coordinator = self.coordinator.clone();
-                    tokio::spawn(async move {
+                     tauri::async_runtime::spawn(async move {
                         coordinator
                             .cleanup_prepared_hidden_subagent_session_if_unsubmitted(
                                 &execution.request,
@@ -1601,7 +1601,7 @@ impl DialogScheduler {
             // This path can run while the caller holds the session operation
             // permit. Never await the bounded outcome channel here: its
             // receiver may be waiting for the same permit.
-            tokio::spawn(async move {
+             tauri::async_runtime::spawn(async move {
                 let _ = outcome_tx
                     .send((
                         session_id_owned,
@@ -1622,7 +1622,7 @@ impl DialogScheduler {
         let queue_cancel_token_for_bridge = queue_cancel_token.clone();
         let execution_cancel_token_for_bridge = execution_cancel_token.clone();
         let cancel_bridge_handle = match parent_cancel_token {
-            Some(parent_cancel_token) => tokio::spawn(async move {
+            Some(parent_cancel_token) =>  tauri::async_runtime::spawn(async move {
                 tokio::select! {
                     _ = parent_cancel_token.cancelled() => {
                         execution_cancel_token_for_bridge.cancel();
@@ -1632,7 +1632,7 @@ impl DialogScheduler {
                     }
                 }
             }),
-            None => tokio::spawn(async move {
+            None =>  tauri::async_runtime::spawn(async move {
                 queue_cancel_token_for_bridge.cancelled().await;
                 execution_cancel_token_for_bridge.cancel();
             }),
@@ -1658,7 +1658,7 @@ impl DialogScheduler {
         self.active_internal_turns
             .insert(session_id.to_string(), ActiveInternalTurn::HiddenSubagent);
 
-        tokio::spawn(async move {
+         tauri::async_runtime::spawn(async move {
             let outcome = coordinator
                 .execute_prepared_hidden_subagent(
                     request,