ai-workspace-lab/xworkmate-app
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(gateway): keep polling undecorated running snapshots

Browse Source
This commit is contained in:
Haitao Pan 2026-06-27 12:27:42 +08:00
parent ef849d7317
commit 80861283f9
2 changed files with 85 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/app/app_controller_desktop_thread_actions.dart
View File

@ -792,7 +792,11 @@ extension AppControllerDesktopThreadActions on AppController {
: result.status.trim(),
);
current = nextAssociation;
if (result.isOpenClawRunningTaskHandle) {
// A tasks.get response may temporarily omit association decoration
// while the plugin/runtime is reconnecting. The explicit status is
// authoritative; never finalize a running task as an empty success.
if (result.status.trim().toLowerCase() == 'running' ||
result.isOpenClawRunningTaskHandle) {
// T3: 给 running 轮询加兜底截止，避免 gateway 始终回 running 时无限轮询、永远卡「任务运行中...」。
final nowMs = DateTime.now().millisecondsSinceEpoch.toDouble();
runningPollFirstAtMs ??= nowMs;

80
test/runtime/assistant_execution_target_test.dart
View File

@ -4161,6 +4161,86 @@ void main() {
);
});
test(
'OpenClaw running snapshot without decoration keeps polling',
() async {
final fakeGoTaskService = _RecordingGoTaskServiceClient()
..taskOutcomes.add(
const GoTaskServiceResult(
success: true,
message: '',
turnId: 'turn-running-undecorated',
raw: <String, dynamic>{
'success': true,
'status': 'running',
'runId': 'run-running-undecorated',
},
errorMessage: '',
resolvedModel: '',
route: GoTaskServiceRoute.externalAcpSingle,
),
)
..taskOutcomes.add(
const GoTaskServiceResult(
success: true,
message: 'terminal output',
turnId: 'turn-running-undecorated',
raw: <String, dynamic>{
'success': true,
'status': 'completed',
'runId': 'run-running-undecorated',
'output': 'terminal output',
},
errorMessage: '',
resolvedModel: '',
route: GoTaskServiceRoute.externalAcpSingle,
),
);
final controller = _connectedGatewayController(fakeGoTaskService);
addTearDown(controller.dispose);
const association = OpenClawTaskAssociation(
sessionId: 'running-undecorated',
threadId: 'running-undecorated',
turnId: 'turn-running-undecorated',
runId: 'run-running-undecorated',
artifactScope: 'tasks/running-undecorated/run-running-undecorated',
artifactDirectory:
'/tmp/tasks/running-undecorated/run-running-undecorated',
gatewayProviderId: 'openclaw',
startedAtMs: 0,
status: 'running',
appThreadKey: 'running-undecorated',
openclawSessionKey: 'agent:main:running-undecorated',
);
controller.upsertTaskThreadInternal(
association.sessionId,
executionTarget: AssistantExecutionTarget.gateway,
selectedProvider: SingleAgentProvider.openclaw,
lifecycleStatus: 'running',
lastResultCode: 'running',
openClawTaskAssociation: association,
);
controller.aiGatewayPendingSessionKeysInternal.add(
association.sessionId,
);
await controller.pollOpenClawTaskAssociationInternal(
sessionKey: association.sessionId,
target: AssistantExecutionTarget.gateway,
association: association,
pollInterval: Duration.zero,
);
expect(fakeGoTaskService.getTaskCount, 2);
expect(
controller.localSessionMessagesInternal[association.sessionId]!.map(
(message) => message.text,
),
contains('terminal output'),
);
},
);
test('OpenClaw task snapshot retry exhaustion is terminal', () async {
final fakeGoTaskService = _RecordingGoTaskServiceClient();
for (