待たせないための仕組み

ツールの中で 30 分かかる処理をすると、その間ずっと接続を掴んだままになります。途中で切れれば結果は失われます。

タスクは、この状況のためにあります。サーバーは受け付けた印（taskId）だけをすぐ返し、処理は裏で進めます。呼んだ側は好きなときに様子を見に来ます。

状態は 5 つ

下 3 つはそこで止まり、もう変わりません。

名乗る

タスクは両者が対応していて初めて使えます。名乗りは 2 段階あります。

1. サーバー全体として

const server = new McpServer(
	{ name: 'tasks', version: '1.0.0' },
	{
		taskStore,
		// タスクに対応していることを名乗る。これを書かないとホストは task を付けてこない
		capabilities: {
			tasks: {
				list: {},
				cancel: {},
				requests: { tools: { call: {} } },
			},
		},
	},
);

2. ツール 1 つずつ

execution: { taskSupport: 'optional' }

受け取って裏で進める

SDK の registerToolTask を使います。samples/09-tasks/server.mjs の中心部です。

import { InMemoryTaskStore } from '@modelcontextprotocol/sdk/experimental/tasks/stores/in-memory.js';

// タスクの状態をどこに置くか。ここでは記憶の中（再起動で消える）
const taskStore = new InMemoryTaskStore();

server.experimental.tasks.registerToolTask(
	'long_job',
	{
		title: '長い処理',
		description: '指定した秒数だけかかる処理。タスクとして実行できる',
		inputSchema: { seconds: z.number().int().min(1).max(60).default(5) },
		execution: { taskSupport: 'optional' },
	},
	{
		// 受け付けた時点で呼ばれる。すぐ返し、処理は裏で進める
		createTask: async ({ seconds }, extra) => {
			const task = await extra.taskStore.createTask({ ttl: 300000 });

			(async () => {
				await sleep(seconds * 1000);
				await extra.taskStore.storeTaskResult(task.taskId, 'completed', {
					content: [{ type: 'text', text: `${seconds} 秒の処理が終わった` }],
				});
			})();

			return { task };
		},

		// tasks/get で呼ばれる。今どうなっているかを返す
		getTask: async (_args, extra) => extra.taskStore.getTask(extra.taskId),

		// tasks/result で呼ばれる。終わっていなければ SDK が待たせる
		getTaskResult: async (_args, extra) => extra.taskStore.getTaskResult(extra.taskId),
	},
);

3 つの入り口を実装します。

const transport = new StdioServerTransport();

// タスクの控えは TTL のタイマーを抱えている。
// 片付けないと、ホストが切れてもプロセスが終わらない
transport.onclose = () => {
	taskStore.cleanup();
	process.exit(0);
};

await server.connect(transport);

取りに行く

呼ぶ側は 3 段階で進めます。

テストで確かめる

test('tasks/get で状態を見て、completed になったら tasks/result で取る', async () => {
	const client = await connect(sample('09-tasks/server.mjs'), { capabilities: TASK_CAPS });

	try {
		const task = await createTask(client, { seconds: 2 });

		// 仕様どおり、pollInterval に従って状態を見に行く
		let state;
		for (let i = 0; i < 20; i++) {
			state = await client.experimental.tasks.getTask(task.taskId);
			if (state.status !== 'working') break;
			await sleep(state.pollInterval ?? 500);
		}
		assert.equal(state.status, 'completed');

		// 終わってから結果を取りに行く
		const result = await client.request(
			{ method: 'tasks/result', params: { taskId: task.taskId } },
			CallToolResultSchema,
		);
		assert.match(result.content[0].text, /2 秒の処理が終わった/);
	} finally {
		await client.close();
	}
});

✔ ツールがタスク対応を名乗る（execution.taskSupport） (368.4261ms)
✔ タスクは working で返り、待たずに次へ進める (2359.1304ms)
✔ tasks/get で状態を見て、completed になったら tasks/result で取る (4369.7507ms)
✔ タスクにしないで呼ぶこともできる（optional のため） (3390.4841ms)

通知もあるが、あてにしない

notifications/tasks/status で状態の変化を知らせることもできます。ただし仕様に「呼ぶ側はこの通知に頼ってはならない」と書かれています。送らない実装も正しいためです。基本は様子を見に行く（ポーリング）と考えてください。

手元では使われなかった

ここまで作ったサーバーを Claude Code に登録して呼ばせました。結果です。

### クライアント capabilities: {"roots":{"listChanged":true},"elicitation":{}}
### tasks capability の有無: なし
--> {"method":"tools/call","params":{"name":"longjob","arguments":{},"_meta":{...}},"jsonrpc":"2.0","id":2}
### task なしで呼ばれた（普通のリクエスト）

それでも書く意味はあるか

次の章へ

次は、同じ PC で 1 本のサーバーを何本ものホストから使う方法です。