From cb276b1c02dbb92e234083dfe4bc02d1594933fa Mon Sep 17 00:00:00 2001
From: BigDataDZ <76271875+BigDataDZ@users.noreply.github.com>
Date: Mon, 19 Oct 2026 16:25:44 +0800
Subject: [PATCH 1/4] fix(collaboration): preserve original task recovery
across busy input
Signed-off-by: BigDataDZ <76271875+BigDataDZ@users.noreply.github.com>
---
.../personal-workspace/goal-team-evidence.tsx | 3 ++-
docs/reference/local-delegation.md | 15 +++++++++++++
loopx/collaboration_mcp.py | 17 ++++++++++-----
.../runtime/validation_command.py | 21 ++++++++++++++++++-
4 files changed, 49 insertions(+), 7 deletions(-)
diff --git a/apps/presentation/dashboard/src/features/personal-workspace/goal-team-evidence.tsx b/apps/presentation/dashboard/src/features/personal-workspace/goal-team-evidence.tsx
index aa85b7f6ff..c6e57b509d 100644
--- a/apps/presentation/dashboard/src/features/personal-workspace/goal-team-evidence.tsx
+++ b/apps/presentation/dashboard/src/features/personal-workspace/goal-team-evidence.tsx
@@ -132,7 +132,8 @@ export function GoalTeamEvidence({sessionId, operationId, zh, canMessage, ingres
{result.task_failure.recovery_kind === "replan_required" ? (zh ? "需要重新规划" : "Replan required") : (zh ? "需要修复原任务" : "Repair the original task")}
{result.task_failure.summary}
{zh ? "先修复任务产物或验收环境，再复核原执行。此操作复用原 Host 结果；检查通过后继续原结算，可能写回状态并扣除原任务额度。它不自动修复代码。" : "Repair the artifact or validation environment, then recheck the original Host result. Passing checks continue pending settlement, including state writeback and the original quota charge. This does not edit code."}
- void read(true)}>{zh ? "复核原任务" : "Revalidate original task"}
+ {result.worker_active ? {zh ? "原执行仍在收尾。结束后选择“重新检查交付”，再复核原任务。" : "The original worker is still finishing. Choose Check delivery again after it finishes, then revalidate the task."}
: null}
+ void read(true)}>{zh ? "复核原任务" : "Revalidate original task"}
{zh ? "原执行标识" : "Original execution identity"} {result.task_failure.turn_key}
diff --git a/docs/reference/local-delegation.md b/docs/reference/local-delegation.md
index 1c5e78a3d9..fe5f228010 100644
--- a/docs/reference/local-delegation.md
+++ b/docs/reference/local-delegation.md
@@ -293,7 +293,22 @@ Current grants, stop state and declared ancestry are checked again before
revalidation or committed-result recovery. Restoring the task output alone
does not restore unavailable source inputs.
+If the original worker still owns the operation, revalidation returns its
+current observation without starting another revalidation or settlement. A terminal
+observation can precede worker release; check delivery again after it finishes.
+Managed CLI subprocesses receive no caller stdin: their request is supplied in
+arguments, keeping MCP and other interactive input channels with their owner.
+Delegation validators also receive EOF instead of conversation input. Ordinary
+standalone caller validation retains its existing stdin inheritance.
+If a host terminates its worker process tree on disconnect (for example a
+Windows MCP Job), reconnect and use `resume` for the original operation. This
+reconciles its durable execution; it does not bypass the host's process policy.
+
中文：先修复真实产物或校验环境，再复核原执行；通过后继续原 Turn 结算，保留失败证据，不重复 Host 或扣额。停止、撤权与来源链失效仍阻止复验或提交后的恢复；仅修复输出不能恢复失效的来源输入。
+原 worker 仍占用执行时，复核只返回当前观察，不另行复核任务或结算。终态观察可能早于 worker 释放；结束后再重新检查交付。
+托管 CLI 子进程通过参数接收请求，不继承调用方的标准输入，MCP 等交互通道仍由原调用方持有。
+委派校验器同样读取 EOF，不消费对话输入；普通独立调用校验器仍保留原有的标准输入继承行为。
+宿主断连时若终止整个进程树（如 Windows MCP Job），重连后可沿原 operation 执行 `resume`，对账持久化执行，不绕过宿主进程策略。
## Source use and recheck
diff --git a/loopx/collaboration_mcp.py b/loopx/collaboration_mcp.py
index 8aa4cf24ff..e3a6ddd257 100644
--- a/loopx/collaboration_mcp.py
+++ b/loopx/collaboration_mcp.py
@@ -28,7 +28,7 @@
from mcp.server.fastmcp import FastMCP
from .file_lock import (
- exclusive_file_lock, lock_holder_host_label, lock_holder_liveness,
+ exclusive_file_lock, try_exclusive_file_lock, lock_holder_host_label, lock_holder_liveness,
LOCK_HOLDER_ABSENT, LOCK_HOLDER_DEAD, LOCK_HOLDER_RELEASED,
LOCK_HOLDER_FOREIGN_HOST, LOCK_HOLDER_LIVE, LockAcquisitionPolicy, LockAcquireTimeoutError,
)
@@ -36,6 +36,7 @@
effect_runtime_request_scope, effect_runtime_result, EffectRuntimeRemoteError,
)
from .control_plane.coordination.local_authority import local_authority_is_promoted
+from .control_plane.runtime.validation_command import noninteractive_validation
from .control_plane.turn_driver.journal_store import (
load_turn_journal,
turn_journal_path,
@@ -737,7 +738,8 @@ def start(self, binding_id: str, operation_id: str, brief: dict,
return self.read(operation_id)
def _spawn(self, operation_id: str, *, prepared_source_request_id: str | None = None) -> None:
- # Detached stdio survives requester exit; the worker owns its single-flight lock.
+ # No inherited stdio pipes. A host may still terminate its process tree;
+ # scoped resume retains the durable execution and its single-flight fence.
operation_id = require_operation_id(operation_id)
precondition = [] if prepared_source_request_id is None else ["--prepared-source-request-id", prepared_source_request_id]
subprocess.Popen([*_python_module_command("loopx.collaboration_mcp"),
@@ -800,7 +802,10 @@ def wait(self, operation_id: str) -> dict:
def revalidate(self, operation_id: str) -> dict:
"""Explicitly rerun the original postcondition; never repeat Host work."""
path = self.path(require_operation_id(operation_id))
- with exclusive_file_lock(path, policy=LockAcquisitionPolicy.SINGLE_FLIGHT):
+ with try_exclusive_file_lock(path) as acquired:
+ if acquired is None:
+ # Terminal publication can precede the original worker's release.
+ return self.read(operation_id)
if self._read_stop(path) is not None:
raise ValueError(DELEGATION_STOPPED_MESSAGE)
row = _read(path)
@@ -1318,7 +1323,8 @@ def _cli(self, binding: dict, *args: str, timeout: int = 60,
if delegated_lease is None:
completed = subprocess.run([*_python_module_command("loopx.cli"), *arguments],
cwd=binding["workspace"], capture_output=True, text=True, encoding="utf-8",
- timeout=timeout, env=environment)
+ # Requests are entirely in argv; never inherit the caller's MCP/HTTP pipe.
+ stdin=subprocess.DEVNULL, timeout=timeout, env=environment)
stdout, returncode = completed.stdout, completed.returncode
else:
from .control_plane.turn_driver.host_process_transport import run_host_process
@@ -1363,7 +1369,8 @@ def _cli(self, binding: dict, *args: str, timeout: int = 60,
return value
def _validate(self, binding: dict) -> dict:
- return delegation_validation.validate(self, binding)
+ with noninteractive_validation():
+ return delegation_validation.validate(self, binding)
def _accepted(self, binding: dict) -> dict:
return delegation_results.accepted_result(self, binding)
diff --git a/loopx/control_plane/runtime/validation_command.py b/loopx/control_plane/runtime/validation_command.py
index 675ebc7432..1e896e9b5b 100644
--- a/loopx/control_plane/runtime/validation_command.py
+++ b/loopx/control_plane/runtime/validation_command.py
@@ -3,7 +3,9 @@
import os
import shlex
import subprocess
-from collections.abc import Mapping
+from collections.abc import Iterator, Mapping
+from contextlib import contextmanager
+from contextvars import ContextVar
from pathlib import Path
from typing import Any
@@ -12,6 +14,22 @@
# Frozen wire id shared with capabilities/issue_fix. Kept verbatim for wire
# compatibility with existing caller-repo-branch receipts.
CALLER_VALIDATION_RECEIPT_SCHEMA_VERSION = "issue_fix_validation_command_v0"
+_VALIDATION_STDIN: ContextVar[int | None] = ContextVar("validation_stdin", default=None)
+
+
+@contextmanager
+def noninteractive_validation() -> Iterator[None]:
+ """Give validators EOF in this context, preserving other callers' stdin.
+
+ Trusted noninteractive hosts use this scope instead of lending their live
+ conversation input to child validators. Nested scopes and failures restore
+ the previous input policy; ordinary validation keeps inheriting stdin.
+ """
+ token = _VALIDATION_STDIN.set(subprocess.DEVNULL)
+ try:
+ yield
+ finally:
+ _VALIDATION_STDIN.reset(token)
def run_caller_validation(
@@ -49,6 +67,7 @@ def run_caller_validation(
argv,
cwd=workspace,
env={**os.environ, "PYTHONDONTWRITEBYTECODE": "1"},
+ stdin=_VALIDATION_STDIN.get(),
stdout=subprocess.PIPE,
stderr=subprocess.PIPE,
start_new_session=os.name == "posix",
From 3ef329b3462774580c905d01d1cd9fbd4ee576d5 Mon Sep 17 00:00:00 2001
From: BigDataDZ <76271875+BigDataDZ@users.noreply.github.com>
Date: Mon, 19 Oct 2026 16:26:02 +0800
Subject: [PATCH 2/4] test(collaboration): qualify native revalidation and
packaged recovery
Signed-off-by: BigDataDZ <76271875+BigDataDZ@users.noreply.github.com>
---
.github/workflows/python-tests.yml | 27 ++++++
.../smoke/team-task-revalidation-smoke.mjs | 34 ++++++-
.../test_validation_process_cleanup.py | 87 ++++++++++++++++++
.../team_task_revalidation_fixture.py | 47 +++++++++-
tests/test_delegation_result_use.py | 3 +-
tests/test_delegation_task_revalidation.py | 92 +++++++++++++++++++
tests/test_local_delegation.py | 7 +-
7 files changed, 286 insertions(+), 11 deletions(-)
diff --git a/.github/workflows/python-tests.yml b/.github/workflows/python-tests.yml
index 2fd9edc1ef..2565e70b9f 100644
--- a/.github/workflows/python-tests.yml
+++ b/.github/workflows/python-tests.yml
@@ -194,6 +194,25 @@ jobs:
if: matrix.shard == 2
working-directory: apps/presentation/dashboard
run: npm run smoke:personal-workspace-packaged:team
+ - name: Qualify original-task revalidation with the real worker
+ if: matrix.shard == 2
+ env:
+ LOOPX_PLAYWRIGHT_PACKAGE: ${{ github.workspace }}/apps/presentation/dashboard/node_modules/playwright
+ LOOPX_USAGE_PING: "0"
+ run: |
+ python -m pip install --disable-pip-version-check -e ".[test]"
+ node apps/presentation/dashboard/smoke/team-task-revalidation-smoke.mjs
+ - name: Preserve synthetic original-task recovery views
+ if: always() && matrix.shard == 2
+ uses: actions/upload-artifact@v7
+ with:
+ name: task-revalidation-${{ github.sha }}
+ path: |
+ output/playwright/personal-workspace/team-original-worker-finishing-mobile.png
+ output/playwright/personal-workspace/team-original-worker-finishing-desktop.png
+ output/playwright/personal-workspace/team-original-recovery-mobile.png
+ if-no-files-found: ignore
+ retention-days: 7
- name: Qualify the Goal workspace craft composition
if: matrix.shard == 3
working-directory: apps/presentation/dashboard
@@ -844,6 +863,14 @@ jobs:
- name: Qualify the canary premerge contract smoke on native Windows
run: python examples/canary/premerge-validation-gate-smoke.py
+ - name: Qualify original-task recovery and interactive input on Windows
+ # These are process/authority cases; dedicated long-path cases remain below.
+ run: >-
+ python -m pytest -q --basetemp .t
+ tests/test_delegation_task_revalidation.py
+ tests/control_plane/test_validation_process_cleanup.py
+ -k "active_rejected_worker or preserves_an_internal_lock_timeout or original_task_revalidation_repairs or validation_process_cleanup"
+
- name: Qualify native CLI output fixture and diagnostic boundaries
run: >-
python -m pytest -q
diff --git a/apps/presentation/dashboard/smoke/team-task-revalidation-smoke.mjs b/apps/presentation/dashboard/smoke/team-task-revalidation-smoke.mjs
index 5a02fb2d75..a3b8cf61b9 100644
--- a/apps/presentation/dashboard/smoke/team-task-revalidation-smoke.mjs
+++ b/apps/presentation/dashboard/smoke/team-task-revalidation-smoke.mjs
@@ -40,12 +40,15 @@ try {
await page.route("**/api/chat/sessions/*/loopx", async route => {
const body = route.request().postDataJSON();
if (!["read", "revalidate"].includes(body?.operation)) return route.fallback();
+ console.log(`HTTP ${body.operation}: ${body.operation_id}`);
+ const started = Date.now();
const response = await page.request.post(`${origin}/api/chat/sessions/recovery/loopx`, {data: {
operation: body.operation, operation_id: ["accepted-analysis", "synthesis-1"].includes(body.operation_id) ? selected : body.operation_id}});
+ console.log(`HTTP ${body.operation} returned in ${Date.now() - started}ms`);
return route.fulfill({response});
});
await page.getByText("LoopX · 正在推进", {exact: true}).waitFor();
- await command("task-failure");
+ await command("task-failure-active");
await page.getByRole("button", {name: "团队执行情况", exact: true}).click();
const dialog = page.getByRole("dialog", {name: "团队执行情况"});
await dialog.getByRole("button", {name: "查看证据与反馈", exact: true}).first().click();
@@ -54,7 +57,32 @@ try {
await mkdir(outputDir, {recursive: true});
await page.setViewportSize({width: 390, height: 844});
const failure = evidence.getByRole("region", {name: "原任务验收失败"});
- await failure.getByRole("button", {name: "复核原任务", exact: true}).waitFor();
+ const revalidate = failure.getByRole("button", {name: "复核原任务", exact: true});
+ await revalidate.waitFor();
+ assert.equal(await revalidate.isDisabled(), true);
+ await failure.getByText("原执行仍在收尾。结束后选择“重新检查交付”，再复核原任务。", {exact: true}).waitFor();
+ const active = await command("task-inspect");
+ assert.equal(active.operation.worker_active, true);
+ const duplicateResponse = await page.request.post(`${origin}/api/chat/sessions/recovery/loopx`, {data: {
+ operation: "revalidate", operation_id: "failure-1"}});
+ assert.equal(duplicateResponse.ok(), true, await duplicateResponse.text());
+ const duplicateReadback = await duplicateResponse.json();
+ assert.equal(duplicateReadback.operation_id, active.operation.operation_id);
+ assert.equal(duplicateReadback.status, "rejected");
+ assert.equal(duplicateReadback.worker_active, true);
+ assert.equal(duplicateReadback.task_failure.turn_key, active.operation.task_failure.turn_key);
+ const duplicate = await command("task-inspect");
+ assert.equal(duplicate.record_sha256, active.record_sha256);
+ assert.equal(duplicate.host_calls, "1");
+ await page.screenshot({path: resolve(outputDir, "team-original-worker-finishing-mobile.png")});
+ await page.setViewportSize({width: 1280, height: 900});
+ await recheck.focus();
+ assert.equal(await recheck.evaluate(element => element === document.activeElement), true);
+ await page.screenshot({path: resolve(outputDir, "team-original-worker-finishing-desktop.png")});
+ await page.setViewportSize({width: 390, height: 844});
+ await command("task-release");
+ await recheck.click();
+ await revalidate.click({trial: true});
const before = await command("task-inspect");
await failure.getByRole("button", {name: "复核原任务", exact: true}).click();
await failure.getByRole("button", {name: "复核原任务", exact: true}).waitFor();
@@ -81,7 +109,7 @@ try {
assert.equal(after.operation.status, "accepted");
assert.equal(before.operation.operation_id, after.operation.operation_id);
assert.equal(after.host_calls, "1");
- console.log("PASS: packaged original task failure, unchanged failure and committed response-loss recovery without repeating Host");
+ console.log("PASS: packaged active-worker revalidation readback, disabled action, release, unchanged failure and same-Turn response-loss recovery without repeating Host");
} catch (error) {
if (workspace) console.error({body: (await workspace.page.locator("body").innerText()).slice(-3000), errors: workspace.errors});
throw error;
diff --git a/tests/control_plane/test_validation_process_cleanup.py b/tests/control_plane/test_validation_process_cleanup.py
index 553a34030a..059549904d 100644
--- a/tests/control_plane/test_validation_process_cleanup.py
+++ b/tests/control_plane/test_validation_process_cleanup.py
@@ -163,6 +163,93 @@ def test_success_keeps_inherited_stdin() -> None:
assert json.loads(proc.stdout)["passed"] is True
+def test_noninteractive_validation_restores_stdin_after_nested_exception() -> None:
+ outer = """
+import json, sys
+from pathlib import Path
+from loopx.control_plane.runtime.validation_command import noninteractive_validation, run_caller_validation
+def check(expected):
+ return run_caller_validation(Path.cwd(),
+ validation_argv=[sys.executable, '-c', f'import sys;assert sys.stdin.read()=={expected!r}'],
+ validation_label='Scoped input', timeout_seconds=3)
+with noninteractive_validation():
+ assert check('')['passed']
+ try:
+ with noninteractive_validation():
+ raise RuntimeError('synthetic nested failure')
+ except RuntimeError:
+ pass
+ assert check('')['passed']
+assert check('caller input')['passed']
+print(json.dumps({'restored': True}))
+"""
+ proc = subprocess.run(
+ [sys.executable, "-c", outer], input="caller input", text=True,
+ capture_output=True, cwd=Path(__file__).resolve().parents[2], timeout=15,
+ )
+ assert proc.returncode == 0, proc.stderr
+ assert json.loads(proc.stdout) == {"restored": True}
+
+
+def test_noninteractive_validation_does_not_change_another_thread() -> None:
+ outer = """
+import sys
+from pathlib import Path
+from concurrent.futures import ThreadPoolExecutor
+from loopx.control_plane.runtime.validation_command import noninteractive_validation, run_caller_validation
+def check(expected):
+ return run_caller_validation(Path.cwd(),
+ validation_argv=[sys.executable, '-c', f'import sys;assert sys.stdin.read()=={expected!r}'],
+ validation_label='Thread input', timeout_seconds=3)
+with ThreadPoolExecutor(max_workers=1) as pool:
+ with noninteractive_validation():
+ assert pool.submit(check, 'other thread input').result(timeout=5)['passed']
+ assert check('')['passed']
+"""
+ proc = subprocess.run(
+ [sys.executable, "-c", outer], input="other thread input", text=True,
+ capture_output=True, cwd=Path(__file__).resolve().parents[2], timeout=15,
+ )
+ assert proc.returncode == 0, proc.stderr
+
+
+@pytest.mark.skipif(os.name != "nt", reason="Windows pending parent stdin regression")
+def test_noninteractive_validation_with_pending_parent_stdin_read() -> None:
+ # Keep the writer open while another parent thread waits for input. A
+ # validator must see EOF without inheriting this live conversation pipe.
+ outer = """
+import json, os, sys, threading
+from pathlib import Path
+from loopx.control_plane.runtime.validation_command import noninteractive_validation, run_caller_validation
+reading = threading.Event()
+def read():
+ reading.set()
+ sys.stdin.buffer.read(1)
+threading.Thread(target=read, daemon=True).start()
+assert reading.wait(1)
+with noninteractive_validation():
+ result = run_caller_validation(Path.cwd(),
+ validation_argv=[sys.executable, '-c', "import sys;assert sys.stdin.read()==''"],
+ validation_label='Pending parent input', timeout_seconds=3)
+print(json.dumps(result), flush=True)
+os._exit(0)
+"""
+ process = subprocess.Popen(
+ [sys.executable, "-c", outer], stdin=subprocess.PIPE,
+ stdout=subprocess.PIPE, stderr=subprocess.PIPE, text=True,
+ cwd=Path(__file__).resolve().parents[2],
+ )
+ try:
+ # communicate() would close the writer and erase the regression.
+ assert process.wait(timeout=5) == 0
+ stdout, stderr = process.communicate(timeout=2)
+ assert json.loads(stdout)["passed"] is True, stderr
+ finally:
+ if process.poll() is None:
+ process.kill()
+ process.communicate(timeout=5)
+
+
@pytest.mark.skipif(os.name != "posix", reason="POSIX process-group regression")
@pytest.mark.parametrize("provider", ["file", "sqlite"])
def test_real_cli_timeout_keeps_canonical_todo_open_and_declaration_unchanged(
diff --git a/tests/presentation/team_task_revalidation_fixture.py b/tests/presentation/team_task_revalidation_fixture.py
index be408dc1c6..84de266a29 100644
--- a/tests/presentation/team_task_revalidation_fixture.py
+++ b/tests/presentation/team_task_revalidation_fixture.py
@@ -1,5 +1,6 @@
"""Disposable production delegation + Chat HTTP for packaged recovery validation."""
from pathlib import Path
+import hashlib
import json
import subprocess
import sys
@@ -19,7 +20,8 @@
def main():
cleanups = []
patch = pytest.MonkeyPatch()
- with tempfile.TemporaryDirectory(prefix="loopx-result-use-") as directory:
+ # Leave room for lock-incident filenames under ordinary Windows temp roots.
+ with tempfile.TemporaryDirectory(prefix="lx-rv-") as directory:
try:
root, runner = service.__wrapped__(Path(directory),
SimpleNamespace(param="file", addfinalizer=cleanups.append), patch)
@@ -32,6 +34,18 @@ def main():
runner.config = config
task_output = root / "reviewer/initial/output.json"
task_original = task_output.read_bytes()
+ terminal_written = threading.Event()
+ release_worker = threading.Event()
+ worker_errors = []
+ held_worker = None
+ observe = runner._observe
+ def observe_before_release(path, row, status, **facts):
+ observe(path, row, status, **facts)
+ if status == "rejected" and not release_worker.is_set():
+ terminal_written.set()
+ if not release_worker.wait(120):
+ raise RuntimeError("fixture worker release timed out")
+ patch.setattr(runner, "_observe", observe_before_release)
store = ChatSessionStore(runner.root)
controller = ChatRuntimeController(store=store, codex_bin="missing-codex", registry_path=runner.registry)
store.create_session(goal_id=runner.goal_id, agent_id="codex", channel_id=f"goal.{runner.goal_id}",
@@ -39,6 +53,8 @@ def main():
store.update_session("recovery", native_goal={"status": "active"}, loopx_mode={"settings": {
"agent_id": "lead", "execution_config": ".loopx/config/delegations.json"}})
server = ChatHTTPServer(("127.0.0.1", 0), ChatRequestHandler)
+ # Drain this fixture's request handlers before retiring their runtime.
+ server.daemon_threads = False
server.verbose = False
server.registry_path = runner.registry
server.runtime_root = runner.root
@@ -50,10 +66,29 @@ def main():
try:
for command in sys.stdin:
action = command.strip()
- if action == "task-failure":
+ if action == "task-failure-active":
task_output.write_text("{}")
- runner.start("failure", "failure-1", brief())
- assert wait(runner, "failure-1")["status"] == "rejected"
+ def execute():
+ try:
+ runner.execute("failure-1")
+ except BaseException as error:
+ worker_errors.append(error)
+ def spawn(operation_id):
+ nonlocal held_worker
+ assert operation_id == "failure-1"
+ held_worker = threading.Thread(target=execute, daemon=True)
+ held_worker.start()
+ with pytest.MonkeyPatch.context() as worker_patch:
+ worker_patch.setattr(runner, "_spawn", spawn)
+ runner.start("failure", "failure-1", brief())
+ assert terminal_written.wait(120), worker_errors
+ current = runner.read("failure-1")
+ assert current["status"] == "rejected" and current["worker_active"]
+ elif action == "task-release":
+ release_worker.set()
+ held_worker.join(timeout=30)
+ assert not held_worker.is_alive() and not worker_errors, worker_errors
+ assert not wait(runner, "failure-1")["worker_active"]
elif action == "task-repair":
task_output.write_bytes(task_original)
elif action == "task-commit-response-lost":
@@ -71,12 +106,16 @@ def lose_response(binding, *args, **kwargs):
assert runner.read("failure-1")["recovery_required"] is True
elif action == "task-inspect":
print(json.dumps({"operation": runner.read("failure-1"),
+ "record_sha256": hashlib.sha256(runner.path("failure-1").read_bytes()).hexdigest(),
"host_calls": (root / "reviewer/initial/host-invocations").read_text()}), flush=True)
continue
elif action != "inspect":
raise ValueError("unknown fixture command")
print(json.dumps({"ok": True}), flush=True)
finally:
+ release_worker.set()
+ if held_worker is not None:
+ held_worker.join(timeout=30)
server.shutdown()
server.server_close()
thread.join(timeout=5)
diff --git a/tests/test_delegation_result_use.py b/tests/test_delegation_result_use.py
index 6935c896aa..8b97dc42e0 100644
--- a/tests/test_delegation_result_use.py
+++ b/tests/test_delegation_result_use.py
@@ -163,7 +163,8 @@ def accepted_chain(root, runner):
def linked_request(source, workspace):
artifact = source["artifacts"][0]
path = workspace / "declared-input.json"
- path.write_text(artifact["text"])
+ # A receiver must retain the accepted bytes, including line endings.
+ path.write_bytes(artifact["text"].encode("utf-8"))
return {**brief(), "inputs": [{"ref": path.name, "description": "Exact accepted source",
"sha256": artifact["sha256"], "delegation": {"operation_id": source["operation_id"],
"ref": artifact["ref"], "relation": "uses"}}]}
diff --git a/tests/test_delegation_task_revalidation.py b/tests/test_delegation_task_revalidation.py
index be60c355e4..a532c7e838 100644
--- a/tests/test_delegation_task_revalidation.py
+++ b/tests/test_delegation_task_revalidation.py
@@ -4,6 +4,8 @@
import os
import sys
import subprocess
+from concurrent.futures import ThreadPoolExecutor
+from threading import Event
import pytest
from mcp import ClientSession, StdioServerParameters
@@ -15,6 +17,93 @@
service = delegation_service
+def test_active_rejected_worker_defers_revalidation_until_release(service, monkeypatch):
+ """Terminal publication is observable before the original worker releases ownership."""
+ from loopx.control_plane.turn_driver.journal_store import turn_journal_path
+
+ root, runner = service
+ output = root / "analyst/initial/output.json"
+ saved = output.read_bytes()
+ output.write_text("{}")
+ published, release = Event(), Event()
+ observe = runner._observe
+
+ def pause_after_rejection(path, row, status, **facts):
+ observe(path, row, status, **facts)
+ if status == "rejected":
+ published.set()
+ assert release.wait(120), "test did not release the terminal worker"
+
+ with ThreadPoolExecutor(max_workers=1) as pool:
+ with monkeypatch.context() as worker_patch:
+ worker_patch.setattr(runner, "_spawn", lambda _: None)
+ worker_patch.setattr(runner, "_observe", pause_after_rejection)
+ runner.start("analysis", "analysis-1", brief())
+ worker = pool.submit(runner.execute, "analysis-1")
+ try:
+ assert published.wait(120), "worker did not publish the task failure"
+ failed = runner.read("analysis-1")
+ assert failed["status"] == "rejected" and failed["worker_active"]
+ turn_key = failed["task_failure"]["turn_key"]
+ path = runner.path("analysis-1")
+ journal = turn_journal_path(runner.root, goal_id=runner.goal_id, turn_key=turn_key)
+ original_record, original_journal = path.read_bytes(), journal.read_bytes()
+ with monkeypatch.context() as duplicate_patch:
+ def forbidden_effect(*args, **kwargs):
+ pytest.fail("an active operation must not retry validation or write execution state")
+ duplicate_patch.setattr(runner, "_cli", forbidden_effect)
+ duplicate_patch.setattr(runner, "_spawn", forbidden_effect)
+ duplicate_patch.setattr(runner, "_fenced_write", forbidden_effect)
+ duplicate = runner.revalidate("analysis-1")
+ assert duplicate["operation_id"] == "analysis-1"
+ assert duplicate["task_failure"] == failed["task_failure"]
+ assert duplicate["worker_active"] is True
+ assert path.read_bytes() == original_record
+ assert journal.read_bytes() == original_journal
+ assert (root / "analyst/initial/host-invocations").read_text().strip() == "1"
+
+ read = runner.read
+ def release_after_active_read(operation):
+ result = read(operation)
+ if result["status"] == "rejected" and result["worker_active"]:
+ release.set()
+ return result
+ with monkeypatch.context() as readiness_patch:
+ readiness_patch.setattr(runner, "read", release_after_active_read)
+ ready = wait(runner)
+ assert ready["worker_active"] is False
+ finally:
+ release.set()
+ worker.result(timeout=30)
+
+ output.write_bytes(saved)
+ runner.revalidate("analysis-1")
+ accepted = wait(runner)
+ assert accepted["status"] == "accepted", accepted
+ assert json.loads(runner.path("analysis-1").read_text())["turn_key"] == turn_key
+ assert (root / "analyst/initial/host-invocations").read_text().strip() == "1"
+
+
+def test_revalidation_preserves_an_internal_lock_timeout(service, monkeypatch):
+ """Only operation-lock contention is a no-op; retry execution failures stay visible."""
+ from loopx.file_lock import LockAcquireTimeoutError
+
+ root, runner = service
+ output = root / "analyst/initial/output.json"
+ saved = output.read_bytes()
+ output.write_text("{}")
+ runner.start("analysis", "analysis-1", brief())
+ assert wait(runner)["status"] == "rejected"
+ output.write_bytes(saved)
+ failure = LockAcquireTimeoutError(incident={}, incident_recorded=False, incident_channel="fixture")
+ def fail_inside_retry(*args, **kwargs):
+ raise failure
+ monkeypatch.setattr(runner, "_cli", fail_inside_retry)
+ with pytest.raises(LockAcquireTimeoutError) as raised:
+ runner.revalidate("analysis-1")
+ assert raised.value is failure
+
+
def test_original_task_revalidation_repairs_output_without_repeating_host(service):
root, runner = service
output = root / "analyst/initial/output.json"
@@ -45,6 +134,9 @@ async def recheck_mcp():
result = await session.call_tool("revalidate_delegation", {"operation_id": "analysis-1"})
assert not result.isError, result
asyncio.run(recheck_mcp())
+ # A Windows MCP host may close its entire Job on disconnect. Reconcile
+ # the original committed Turn through the existing independent caller.
+ runner.resume("analysis-1")
accepted = wait(runner)
assert accepted["status"] == "accepted", json.dumps({"read": accepted, "record": json.loads(runner.path("analysis-1").read_text())})
assert "task_failure" not in accepted
diff --git a/tests/test_local_delegation.py b/tests/test_local_delegation.py
index e2bba4c897..44c64121f5 100644
--- a/tests/test_local_delegation.py
+++ b/tests/test_local_delegation.py
@@ -73,7 +73,7 @@ def retire_runtime():
"from pathlib import Path; import sys; "
"from loopx.control_plane.effect_runtime import _runtime_dir, restart_effect_runtime; "
"assert _runtime_dir().parent == Path(sys.argv[1]); "
- "result = restart_effect_runtime(); "
+ "result = restart_effect_runtime(wait_for_exit=True); "
"assert result['status'] in {'stopped', 'not_running'}, result",
str(tmp_path),
], cwd=Path(__file__).resolve().parents[1], env=runtime_env,
@@ -264,8 +264,9 @@ def wait(service, operation="analysis-1"):
while time.monotonic() < deadline:
result = service.read(operation)
if result["status"] in {"accepted", "rejected"}:
- return result
- if result.get("error"):
+ if not result["worker_active"]:
+ return result
+ elif result.get("error"):
pytest.fail(str(result))
time.sleep(0.25)
pytest.fail(str(service.read(operation)))
From 09d05ffc82c43c55a5a4a5eeed0947f97f107eae Mon Sep 17 00:00:00 2001
From: LoopX Agent <337587101+loopx-agent@users.noreply.github.com>
Date: Thu, 22 Oct 2026 14:37:01 +0800
Subject: [PATCH 3/4] test(collaboration): publish recovery viewport evidence
Signed-off-by: LoopX Agent <337587101+loopx-agent@users.noreply.github.com>
---
.../smoke/team-task-revalidation-smoke.mjs | 3 +++
.../recovery-desktop.png | Bin 0 -> 123674 bytes
.../team-task-revalidation/recovery-mobile.png | Bin 0 -> 54340 bytes
.../worker-finishing-desktop.png | Bin 0 -> 132001 bytes
.../worker-finishing-mobile.png | Bin 0 -> 62015 bytes
5 files changed, 3 insertions(+)
create mode 100644 examples/personal-workspace-browser/assets/team-task-revalidation/recovery-desktop.png
create mode 100644 examples/personal-workspace-browser/assets/team-task-revalidation/recovery-mobile.png
create mode 100644 examples/personal-workspace-browser/assets/team-task-revalidation/worker-finishing-desktop.png
create mode 100644 examples/personal-workspace-browser/assets/team-task-revalidation/worker-finishing-mobile.png
diff --git a/apps/presentation/dashboard/smoke/team-task-revalidation-smoke.mjs b/apps/presentation/dashboard/smoke/team-task-revalidation-smoke.mjs
index a3b8cf61b9..a606139d2e 100644
--- a/apps/presentation/dashboard/smoke/team-task-revalidation-smoke.mjs
+++ b/apps/presentation/dashboard/smoke/team-task-revalidation-smoke.mjs
@@ -95,6 +95,9 @@ try {
const recover = evidence.getByRole("button", {name: "恢复原执行", exact: true});
await recover.scrollIntoViewIfNeeded();
await page.screenshot({path: resolve(outputDir, "team-original-recovery-mobile.png")});
+ await page.setViewportSize({width: 1280, height: 900});
+ await page.screenshot({path: resolve(outputDir, "team-original-recovery-desktop.png")});
+ await page.setViewportSize({width: 390, height: 844});
await recover.click();
for (let attempt = 0; attempt < 30; attempt++) {
const actual = await command("task-inspect");
diff --git a/examples/personal-workspace-browser/assets/team-task-revalidation/recovery-desktop.png b/examples/personal-workspace-browser/assets/team-task-revalidation/recovery-desktop.png
new file mode 100644
index 0000000000000000000000000000000000000000..e7afd9ce1765e631c3affe8897213a1975087ff4
GIT binary patch
literal 123674
zcmce;cR1GnA3ti(?7cHW*^(XMwjxr5$gY%m8=2XAhODfjsAOl8P4*}udt`6f>pX9L
zzUOyc=lpxF^S!R`=c7->eZSt%@mQ}r^sa_75dl2`8X6jrstV#B8X7iyi5Y;00slg}
z5Ne~Lk)o+0e|;2@`QYRukXEw
z-=ua4zU+&2zHxoyygRwXg`7MjMtVPas-BWdq5>GS(J8fzR3
z96o^|1{$g2Wc2j()0)Y`k2~Jn$oogD15s20e<;-iHhfeVTFCe
zPXW8!rN4yd@*WcP-ZQ6
z`p_f751a6J0c}gdEd~~;7hm*Co`|-Oezxq-w49>mdx$7=UNt;ZZtG9G{*<_(ZhgEu
zM>8Wm&qVoYPim#>)=U(t91thu8EYo9uNTFNKhP#zULLAHyXmoK?eyX@KmQ$RF-6pY
z_)ZhSDO0AqO>n9u@~;gSvD*sv2%Z(njwT72!;{b|vmU8*TnMV(OrMceV@*MZvKvYa
zxctbzGu*>V+amKeuH1Iqy^YCbI9xzEiqU!H*G=c;*QXsu?|MfRQWwIgcqH>Dt1a5e
zspays76>W1r;JC-Y({^5(QlfdzIyLHa<=t(FE5-_$RfqXi>19$d`0ui&!uX~VG$|&
z7HcH(*-YKlVmLAUOJ#x>4sB6Pi$-%FDoev@1fIlViCT9i@TtD$*7Bnvnl94*bdUA^
zkIJcEL4kph^fx}=eJ8K3RB;CH@U1VD&Lp?UW`CA4S?yV2M$X5fJcHo3Ha|a-71Ur8
zQky87OJ&(bv&c@oQwU~Pjxv#(^g3Rf@T;kr?@k%2adQ+ofrs!Q@1aiK!y6aP$41}m
zC^am8B|FlZ;_jOA(;rBu|MODah0R+d@TNNAc|6z>zUrjznfX=}q+hYRd?U{z4@y&s
zNmzua2CD0`POegt?+p*Cymq&#di1uz2}|7?V`(ESQAc@sdHa_mrh9pwhuf=s4op0>
zbg6s>q6Q~_mwv3$_6XLATK&3|@|z6R`5`#?!^EN*su+>hv(p33qxw}3(50XDFoxAp
z#uWLdTKQu*Ee(9I8vGnMG=~>sU4OMyl54nfLVdvKT#vaah^Q%tD9LSgxM#GX|GuYO!L
z66-($s^P)0N=N8v#LDa?A%y4+|-#JPBkV{h^Ou}+@cDyn4MSr%L
zTxIbJf5`IjdUf@|J6C$0b)L3vT&h
zgqS+5F8#<6vzxF!ePk+?$p46b*JH7dm0=X$x7*uG(tfHQ-b8mNVN-I~LQk6G#gNEs
za~@yOq2%zL4GUHX$tZD(ClKQ%i{FC54T51n{{#@qzOL`+ig*F-w{ViW5`t?=lv%16C$srMgC{}NT`_+}Y<*>JL
zDL1TwWJrjJO5J;4H546+jXO~YrzEA8mk+l*?o5C|^kw%qya2wo!LB_kc<2nG)=2>=
zTNh;$vhq5Yvi=vDMk+Z;3MpHD`>I2WHD2ehJOhuocplxTyRIl-%NcbLHn(0n6Nv^~2OWeBR?j)gEsvX45`xie2kF0A~
zk~02cbCSv%-Y9v}O+Z3Y{x^Zopf#GsyG0SUfFL~LEahm)(AZj!eP*c_U8-19k8Q`R
zP)%|o>vd8wgx{0@s2V2aGza&PByr(?->vyNE(!C=?vSx&hD;iC6X%^bBF}$X_M}Q!
z{)R#OxGQO^M{1)hMa+&e-0t_+rBS=O@iLo~$D=T8S4T?v%Z*A3U{2z=-1dZ{-S~FA
z9!O*KJ^6Z0oPA-2sNn~gwGsn4nzApCoX&=Fb$e5K`?19=!taL=tEWlseve_ldOzEu
z04B)rD6f98h|TY>_S20!^W8k!A4zFCRmEY`{(GfEbnw`J7n$P@B%Ws}MatjblJ!12
zX$hlJz}c~aVVkAr3ELcARnIHdCK%_|8nCWT{A3Ovrk1xgs^3cKF)G}4
z=3%K9ia2B>1yGFsT^X{2eM};IVt;}~es;K!0kfFT>erWymwU-W)f-=*{qQ=N4u+lY
zz1_~$zqF`U+&XJJm7ckZmyDg-3
z;S&-v$aso}!t;H!toyIHo4Z=VY3dH=8P1;erl++--@yLLgoE5$*;^Zhp}j|Vne71Yji;Nv~~yEeKXDK?QLXo^9Wg@H}*HXxKdp3fk`GVUKl2~cT<
zqH*4ssGZ;-pjHiP`O{rFLmS8Q;L9fcuT0_@W3=Ou3Z!{|refan=cUgFQ?bl?({BPK
zvm5-ZV_%CLdzR`(QP0ZCy2!~T7fONNg$*!85lZOCdsTDCF7!Q%O{gDe-eCNwm&?sp
zV4y4dmgGTQ+FQL?9qwnliQ{q}dqpi|k`g)&I{D;z_6a;b=)+$nPc^BHYh01PzdnQK
zKk`A1Mv9S*2cA-jka?>>-H8J{J6KFYieZ!=XAq+*xBgXvsYUmjQfNIGwKtdGA8Ep#
z`G%Dk+m{%{3v~;OjQrcsm_1gDVEIbo2M^&>e-nu%Fvy2J3#*AZ|A5IZ&E%aIyL6n1
zSqF4k#*+cnyEAi6CZ3bXHrOhw;*RqX-S~@Zk^t5$rU>q&OOJ$J@2h3;I$+($)%7z7
zD8zD{@Z9MJ$iB&=bW&*Aq%!sMe8pj^-WQj}^A%6qcvBAvop1n_ST{3G6n3SR)wk2V
zQP>q#?z_t*G6z1R`2dJvpZ*VFhcb+*VEN%s!8w{mV~f02d=HgPaGh5eJ#`Ap$v9|p0X|R&tgl=#HC{JtxO9k=WSY;!gzpEOtB!bT`nT4!brsfV>t3L1XoTo|;*
zqYT=T!rw`A_V%F>HPWS3NizXzj{O;RBEAnN?H4v7vQr<7vGwrt0OF<<=vO=qQLy#>SSw|LEw4rYv^XT;$zM
zL@3Y%13b=O)99Y3yF;o@tHUvQ;zd{wod8ipjV8-c8VAD26?{90Y0;CKyb#hGTE}!o
zbvP3)FwBPDvXJi4^ABq32$p~07x}wBew^;H{_OYHPmZUzVv1pepGm+_F#hK02Ag!I
z(mNAKi~iMqB(^=nY~47YhYO}$pOvVMPD5~CW|{x71{9HNtF$K@;MgH!8U0|`H>9|A&ePPztgC9iy<
zgY^=F=%q>V27kI4Nk83sm^88nQ~uCteGEKOTTPgc(Z6_X)QV+i;HGW@m$M!%i@clr
zy9>pd*|dD!OvWjX@$vEXYu!sf3>6qh<34eYNM4HGrT7%B<$3-a9_6-wWfG4rKcXAe
z9Zc%zEe2eAcvmhNz1Cg%m3OmcL9QS0NTutm^6?ibaeYn=L+k(30-Cp%ZgGG6JD^4)
zz3H=n1~Yb)5a*T2fEtjx)#{CJ;e@*@71OCA&jtz^;Cq!EE&jSUW@vnTz5%Tm6l7+B
z)*xxX6>WBwa!7C;X>BLxIV3)HtB(`hkp`b
zqc2y8oxizZ)fz$P|1M0zu-1L|W3`?NJO`-h;wRm=*_@Yu_J5JG**!5&lyqJmbLiyL
z?J5JF#+7jS%_6F8LuqfHc=iGJ)00A(n-Sh#g7L^KWY!$TBxU`D`s_ZQ#Oe%@
z5(SgY(IUGOdZO@UrReV{(8E-Y`L=~WA$@k{aZ_*jQ*_2Y{Dih~m&wRRhp}(j)*3a=
zet#+kPhT}qaH`+Br}a%SGArrTH(X-IDJQ0z?q7ivZh2<1aqP{apY>!+!~WkN*m=a;
z&7@Q|{P|qkq#kW9Kuo{bLN%f^{iX*ooiJ8h9<=!{KQX`+Vw0XFk3Z^{aF+L&N8fx<
z=k?O|@`V1!5!C47F^wsoa1T#46vU8+QFQH5l}M;v-D$!(;G?2pr2?bc2e2jp<^#<)
zGS=ZlNc(%1GJjXA+I$W_NK`H%P0A&KN0+#^c_n*!y=EHD8Zwdfs#<5YOW_OrB^cUBWLe684?$H2t?n!>z>H+Smkxc1I@)$30Rfk
zRT-x0{Zi`{O>g?;hw>khFi8d+-Kg&LCx4?WC#f|J2ZoEAl$pI-HSkUWw-^1zOiYSx
z)hBqE-!rG1f*oUHs_`5=Bw+@{OvPtJiVHPwJwoPY_W0A{*)W3NQ#s!D05)@~tMkvzk|qtgx6<1}Ta
zHD=R)lKy}}iO9SX815Vzc2d7_J45E?)(TASbeWgG$&fe$#4CfcIWcNZ35twwc%Hm=
zK<2a5XcYQ2$jP0sN6%KGwd0EvJ^E_dKT+$!BI}jf$oIieoAp8ArxJvGD&7>Zh;iqk
zN2f=-I|dD2u2Q5)bRw3o9J_0v?X*tZOVm_U@C+_3I=$Jae83=ZHKGC!H_vPyCPJ`&
z#?||rb|V`6=n^Sa;_}T{1@o7X!snhpH)xDK`?K#b*w%=zU44jZha%$7nCPhhK
zUM1B%221aoXQfU^al@Z4JPv*q=z~{CTd~&2*XmbLq@{u_ps=Whn*?_2$cmyWUJPvr
z1v(=&^X1)viA%wJfFpTS
z>F|LaNL#aV&hQWul_4Xm85LW@gAd6Ftwdm3$0=zBIac@TP=6`bw^x$W9w?v=&BG9c
zA80LGSWg5d>%Mz+LnFXy7JkxoF%#JEO<$TZiQ8Z1WBY&$NVV+zXhk%9j$0%s~D5rEA#s
z(tj<|K1y~{vuRv?@FhuC?&7pnFUf2j)B_`RM!bHnk#+=I6!kZYi;DB_&nyfy_v%;O
zMpt(m4>g}LrI6Hpz*=3-npYDCS@eMY4%Nm3ehv}?CnIaV_nS&Y3@ZRu
z^7@PO4Q{;2^0K57L1~}KZ&dR=RNhu%NCI&a9w-Hq?hpDAPVHpDH<5O;ivx&r-WCE~
z?=V1Mr?7Z4hth^QVK@P-C}&4(``EpEcuoM-sLI^2@A;R6S$Z*qCuX2URYQ+`G=RLm
z-_A1yi@$p?V+Pbin2WH-CDamlM?m7-nr%z7Vh6nXK`pWM0A#Nic0@5Ny#N2b#NOJ^
zx5B?)mhr1}-&@tMxy9wBigD+)d2?wiEq$f9d`RvUnOsj)C$PP{h1OPAMm9wD1OpV!
zm?_)PU^$nVF(5AH3Pa8$gF=dYB!Ma>t_`Xe!nA5SB@}H8Mekb1Y~_{>n;eE7>f6A<
zkYl$Oo;pfralc0W3jR}wg)bD}|0iF!qNDmDfOH6b;SroUJkBdz{Hif*iXE@70xyZX
z79Z9j&vE0g_JwvH(yXDUM_VQG^5}2KJ#r00zxr>$mjU-4Wbi+dRK|-5c!l=w`-Q&Q
z+_ZPH3%W#?>Wc20*7^s^0?$sn99r$#f8u*cb0RAYH3%^aD<7IRA)yEakCT!}y5j1k8d&DNEWpjk6jZQ;?yVR9I~
z^1~mdqe_X=%popF;bS{ceM`U?6L9O)0U7G^{!Yq+y-ACYpaR2+k@V+{s92K1RJ@yM52K4JVF8)@xO-^8ujzj{Z1?m
z;eg=aSw~5>+absHnW^GRHvg#%Do+2kf0PP2DCu&MRRt=awLgh#X)wku&$Y*0$kk9;
zLdYf}F>$s}uL^G*7SP}wH7k^!YisQzxDez@{Ve~ACYCBp;lKI;zvClOAt~EKP-f@B
z7l7001w|!*PSkEfJ-soI5L&Y{MFRAUwb61wP^BoKUEmGm^@~JyxA_aeY_LG(0|^H6
zA4yH+j90s8rik*vB8MgUPnbhJcD7I<7{>*5XOc?c(%awJL0Fa_+gl#wnaY8^UkA!a
zf*0^9kcq`W+ymsTRFMt}U>!)BKrOZjr(i#y11J)x*_8i@Aub~F)u7xKr3(t0+yWvC
z8Vke7Eqm@ckdfTupdLK;MxIJJEt+7UMi8*-y&phRkM=i=GZFZ8AM=5}!bk-VK*Zwv
zD^1x`5m1&y&qKM=Lo#!^4Qwkvz|{PAo)tYY@akps00K4mVFM;#ZWaOnr}W3(8`O#$LA1HU*J7%6_NP&9giPr(@w7^qnGdwDQd>Y|>I_>bQKZ6dGc
zx?|`C3~hI1$Yt!vse-Wo%N6D6HP{LlJ`5bB+q9P{G!Yrg7sER!&n89Bi-u=<=IRny2~b`
z^&|;pQQV~F)$_>;zs!a5YcvyJHH>TLx54TC1=RCiB?dJ7;ks|TF|bwBeA_JOJGd9_G`+)(Qs2=sRp
z^eILtR7iu#3_E+1Q@8knTZO2p$y*8&Bz}hmCxk4SL`Z}hswaYYCKFV9p
z>x~4iF
zdDmE-xA#Pi+lWYLwCtI9l;NubWemL#*DEmm0kWP!^=+}j=34Z$U-GD}|RP3`dY&)1e
zoMMnYKiN6SQBi6{GK3Ue9(}p|DQCviDbrPfB%KsVn7sl9Vc#=uO@u%}2`DNOw(;g;
zLpVhA;&AxqCviimEyOo7?R{KUhvhyF3~)UXH~O~DD=&d*+9f3h?3g3zuRsX7(kVHf
z_gd)?l#)zlENUsAIcGKiPLCOhzPXn)OPtap6Tu?;?d9SB7igDh5ew9NCZ)6+H;D-#-s7Afv(
z8NWD`ORmb$5e%>MdJtb|U*BC0{tq;s7%RGgY($~Ok2|0ArZf58PF?^7`L+Gt>WJg=
z&#PYJwI1a>{ZdbSpgJ0
zu0a*G5Xs76zAt2_*wRZnS;Aa(8@f#C=D0;nKu8EW_#=x)Hy=q6Qu8kU$kD7yc%voKU+G}v0a9OQc*0j>j({y&7pI@t7V8(y*U?~
zaAmhUhj&6HV3gXzHwy1x=Ip?Hui0vGrQ)SNg;Ti`I7^!!*riBdkmcX+!-qjf!a^fc
zafTyjSG)TQxaJNpqbqNZ0_kr&f9nggT*|CD1cob?NG(}AMOcVqN?F|hv;cARv9Exq
zvrm-Xh4>kQLf&5<#UPR_>3j`;-d@+7aAUMQI+F%JOko&}GQ$sd2?qBm93E3SPu$V&
zO5Og12W3@F`fVPa&wtm-C(m|zWhqBN>RJ}yZ2&=gI1UECo1+S90O`JNND;NkRGE)2
zmFD)D);1t&#zGAQ@uvWOqekL16jQy`zrvjCdVNFR
z3WxEM!2OvJ&;>8+Eq0H6dnwhJ)C@u@(-=EtPuc8k+culPMsysDkS|5|VTtLRf>?RC
z2GvoH+{IIo=6F&u3SJcT5{~m>gC1CrccjB?qvQ&L!|`f9wM>egSs5
ziUVpioG7nvPl^=gc(Jdtv&%GmV;ApqNvK!@?E0|GdI@iudN5@C{+KYKuUU$2AQ9+f
zruesGp*@&HEJ+o?Bl~SnWBO6A`>A(BFOmrJ_4PlRwv|A1;1PAJyDJKF6zTlx1gLX8
zrVUJ?uj|iz7BA5iM%j>;GWIF)3iqT*iGewOMzOf{#K92Our&xKi=}~5s9ahe
zLNc(j`-I*Xd;SxTg_cZSdWft&9d^Lo#&=(L!2Wi$yUV@J(+XWLaOWzaY{Ir)J-zj1
z_1o?bN@X$#18=P$gJvGwQj~7vBXBQg$=}$VZnF7`a@}?&PZnUWzx|MP)hDLowOveg
zl)*^DVZl*Lb(A}z>i_|@Rq?0qoq|dOK*V@%Ei>3zU<1#UKAt@_!2_N$9BMwywowg=
zVC~UzZXB29Ub%lHsm0tYRs}Dxc5#_q>sL6N)vep805*i@Ql+Fvc{EynRQ
z_rO*bI-?NyQ@vi*$rc4Fn*reO=hX*0h1am`VSLvtcSm`cxwX5;;ptj2m_L$2sBqEP
z#hPHbr~7;y!s1zz?H%WnjW;^
zzL+8J8V0c;rjJROM9%7tTxO8&G*3Z|pWi76>%6ZQD{g8?tkcTZc*9Q8tV5fRuXS3w
zCrsM>#4X8h4N{U$i&OF0
zRZdGN{6@yEeNQbe940p4LZi~RH_Hj%Sia~xFmUhArK(Bp4fC~
zcf}@mDe}7ABrSn@|Cdd0(b&k$*1Wd7wwh1Yd?~201d-EVPm#Xgi&hkfy*^xt3J?`r
z;4gvIm-K0>!uba`QtMKQ>TN@??(11vZ*L{E41K77f~i0cE-1Io=hxn+7WLmB>%c}u
zt*$q)*gg6SjO%>Hhs*6Ib&X$AN&g6ypv21?Q!DCFwYXTb!{29_zbj&K1aW8;0f?Oz
zkwi8@cWqu*{c1I|4lY1s|1H91;#}=der0otV;{BHvGQhv7{~@r+SnEGJ<_&H21nf`|MIqMw$OEAu7g#GERpJL6!DW$F`>gLWjn)F|kEfqx8J;?HRGxq2Zf
z`|sb*2pg%aOZ~aoXl`rF(yp5jcwl`A38qaJWg7IZH)O3wfeGL&#-2~U+<#R6xhrUG
zyjm=18LW|de!hoaLrBq%Sf1Va+m9sV*07EPPZ(I>q-^kj(yd*)67Q|5+7h|%KCe7M
zg!ki-E_hfPc1!6elO+V;RHU(TC#SsLQNVP6@S4w{3{n^p4s-U9Ak3g<4HFUs8w*^P
zsLWY#k0VW|mfHRJjm`iiF-bTyOBN6W6^{WvyxKCDXW#;!@aq|r5%z2W5PyB>v+=4@
zZ#~inf9%TUyPaaGLDgwyK~)!`8$6W>_Ns7NgR$ECApJ{1WMJjxb0EP+Lw6C!2kS~j
zQ(#0$InJxMF{$7OCx{6YG=iQ6G^-mawQn_CI1QN|7Pq;WPzo*_C+aoaKV9J|hzyyR
zo7&aRD@v{d$doIyeG}kz!+tWh#|_D%O78V+H(REfT9g$Z&q%>
zFuGU$!iHRr>B}bYWRorYMqL2)y^OL*FqL{=!xmGsH-61(7i#j@7thK@`
zwLPz(TkaKGw2RxItsWd1wSF!wtEf4H5l6b~vY%jJ3$77}mcuA#<430l>6KO8&jq!6
z^gJVwHMrg@ZC;wi9#FmmvV>NI=%R!o(MrQP(CH@#TqkMTaMIr=P&ucL7?KPOUFAmz?A)BH6wAmMOzpGvB&Tkj8L_Ut#JS;Y0oaH#zWy`drTlNj=*3qctd3wCR&x!9Sd0y%*M3C;e-3~!da&ADec6|QH
zgN!tsqBsWwAJncEd_={z3U>SPNsudV!dEpeR)@)4E+K~@=jwULabmIT@S1xKnAZtd}F{Z
zFsyXY=rV1SIhexK&YyM1h#Gx210yrk%nU=1=2tK=6I)MM%GxeY0}WnfHCQO1vJB4u
z1p70e$>T!QA{&BemD1QfzxPhAAha1W5rj8$bmbxqbs}h-{w``=V!WLU8AVV@XCL79*qW`U5s_y6knMTzSn#eE_MSSz2x6%poht1nEad7=`_9OG+=`2rH)3|?Q)rJQWLX+)GOnmmW9TgE7#eFhTRW?-
z>6k-|*2rN8Sc6O-hc~
z;;@Pr72({6QZu*T=FA+q)zRY)2eA45c%EsVvT1J%%ceLrv#jyI3dUSQ<;q8ofvMs7Ov`+BhR{48La*y)79;YzTJ~3DfdCp
zx*)?t);A~oye57YkI%4z^fANk+fRD;R04rd+kz?xrZ;-+u(GQYv$cw%4VlY(m(VBk
zU-%Q|w=OXguRjd=cI50CeSV{{$(afp`)2HgX4oE(`%EYtedT2G!EdNVn;+ScVy&UG
z#HBN*w>2(Nr`S!c&kX2k77Dc(n$v+FY-}P
zo7!cN`))F(oezDCUN4OH!Ty(g6V$$|e*5z4*a@GiBI4Gk(tj77ZV(rKLezE6P4@To
z^?@b-{`PL2Raq);{7sJ+DgH_={AWM}QRX^=#M<;dC)XdSC{S+7*7a;OF)p!)KF!KQ
zuoxPuTWj-l&{5FF9flpY2jM*xd$BR`5)wMP_8&a{rv;p|X|be5Mm%>~>}&AO3}^!a
z54Q8;C6uP=4NjbBXkb182kIzPwwpf+#i-2PorhpvjhJLi23A&>()U!Ee
zuK2l4T_Pld)9-nW*Ll}@Z?rG*{Xr$Sp^4xDw1hH$>|m5|*kr30SEQdVF80d3{%mFc
zR-3yN^_`G5du6i|vj>U1`ohaDL5xK8Bk4ywjU|j#cPv7@@pChlH_!hmT*x{2))2mA(Rc
zZ;$60hp`WL%N2fz{fS-;T@=xW@MD2!t~430;9QUMJ%2
z!=p|jtlj|%=8AZG8?Z+!r5BCbsEStA!M#7}#>*0y?1`plG>S3fPvFdKpv!$!U3M`G
zVx$X0>TnL!g)b8b;wdO7V5-YaBSFgQIN9n`*c`+&k*9%Z)Fj9na-U#$W!WJS$>v_1
zoY&}4nKob)ov9MnXI@&a*HL8jYPEpeti8^7y_gK^Xoxw@$LF0qX2KaZv2@eq8E
zdtplW-_P!tfs~K_%zk@Ll>=Wi{j(qa*k%BZHD&a{($2}X6+LrTBe-ioR0EMqhOBsr
zbMMGc_XZ1$S?*N4SbMl_@2eJnjmk8mix;frLpUTUp@vM18X9ZzorJ$Y-WPf^dQ;dS
zytNvdbFJHIS4mPaxlJ2w16kw*tAVMU!g1`8fC5U{ll?4y3r+cj)0wI6%3v-RIx3fs
zM~3~&X*Z2PA40ncdLG_PJRs{fI5ik%&+vXQvCL+@pj
z)WeQU#c)PeL?iN!1KBu3%gW^mLu+C?dE#Gg!TzE9|F65O+
zpp208v1dfPqAvWr)_4ogYKXtr3?#&ETT3KC!u|guHM1XCLBxn#>KlA51$h
z@~>vtuCl>}ngR4b33r<~IO)WFp-%tVRET>BowtE1l7=;|TI1r6*i&!qGICy=i?)`&
ze#m>wjyttRsQ>)WSqym}*3oe>X5k;P*#Eu%|JT>LKXAl(d3mL!Pr&tfewB+n6&3OY
zq71GveYFni1w(n<5Td?FS&#J#YcVa`DszYc
zMDu8O-&IMv_}5D=N~OTnc9Xo|ftBcb}gdsYV_a$I_p;e+eC98bU>
z`IO$C)ehKAvF5FDotN}aXsJVhh*8yVJ^EWgg{lGu0oH>?56A^jMdD#P;44-uM>8iV
zZ7~De0Ut#45LDZeSg3Ox0cVic;k)eu$^N#Kog#Cx+2mskgVVK>ul$uI$ffl+_;m9P
zK}my9nlV76y;RI+zrN7zsAhevwT5im{5c#>tpo(`__RO1`iFsHg>L5fDs^%5`(6nsIbc<(fjy@iUj?)lpm2i(SvmMX4c=v{Wu52n2S+&Q
zrG$wDP!-J@O9CCiA@!;nPq!`aS(o=;3y9I3W^sdzNt?EWZ-SXz1=l^kew?MR;hqCc
zeEhf+Xri(A>29L2S18uY$gD*rf@5k;lGmmtKG+
zxTsur-UMtJe7H>&VJPwxa#$b+9D+MH0awTx2s33FL@aM%WF4R$jPH*`t=yh8Jo%vv)D$2En-7E_-;U=}j
zM*@D)Hmnl2o>r)80`RF(Uj0SmvVq-)ktEDLuSq$+nGL52X~=#7pNCxefPJGkhoDkW
z%N}6ngWw;NqmdmI@(4MIh?B*QmfLx6HsB^B&=xuq3qU)@n*wI(1SJPEru`MGzoX9P
zFkCgr1_cM@%&KMS`tLxl8Lnh70}1+?Q;mxEvh;_ewNjTUCndIniqO#o1Ac}pYp}?V
zeQXgj9A7&5{Sy^HL<0+mc}zpkyz=5UBF9s+J81W{PeB;hOp~N?7PU@=z}8Kj&z3eW
zaC1gu4&wl3gZIgnGFYOd^_V!9AW|H)|3jJOWx(JpTpwzH6I=e37p@P2Kp)I|FacW6
zMHJ&eX><3G>Ol*eHAb6CUXg05pjh#rw$Q5hUrw
zAc%~CzV{w!g|9`{`UX%VL=gS2Lq!kasgWBQ-)9ETmbO!`EdXWlwxj~}^#lVIk+tbd
z*7V@Rh$|SGuJ|>e-)L
zBKB-xuB2B6ZvG56hf+AseV@Kq10fdb){^xwS%g@!p|N00UFvBnm<#<9C9-4e_J_)j
z+yzhZj$fu5INr5~P%EP#w?Nrgtl=bojq(J&M!s<}CYp36tSdv7rQZOIcNmnD5D|=)
z-o^{t0^z0|9Ee-x?V8eC0d-q8^}~w0kG@dwrd+ojs~~2Qls-F{<-TV{QUfIi&x*>q
z2!~j=`MFt+N{nCq2#`=x{S}<|0-5^|aFjsKAb<$w?ep&8N>zb;4&e2Tw3`EWsYW3v<}S{8xGs5kXPE7l8k1oMG{NBpI&y8(f=m(ayuF0+Lc^-`c`1#GyyS;^Yr99X+s
zF6oT=<^g!qv60L--{e#P(=+zm!p7&F0cF?>dlJ%Q8tS*kwsGopAOcg;&H9a6FmnTF
z@Nfr%U5)RkG-!c#GRgsDrzbnTYN!7o78f-($`D4S9Bf8KzoetuF$r~7X)d(zekz(5
zCaW0-!B>w&iv2>W4{6z;)7Pf)Rzb7T}g88%^_s!
z`9`%zkmoU*EDQ`LVt4_03gE+`Ci?b?KmW}$eKIQyamWF|SVcWcd$K)mv4m?n03_P!
zc0Y4-+l^Q4!Uj8m=f&u9IS$JDDcsUJBZhmvU#{KAH-Vj9V$q(NX*1xH@*bY~VghKV
zQA0SJ$IZz5)OjU?Zg+9x@pvy}
zin^00;d0iykN+i#q#IE~n2j#bRQ!WKEu&{OoDMoXkH=+zYFSZ1=aA*d|E>R|X6fKw^5pN)(OYxPl0c
z*Z;8%z4c02LM>S_=%EA!;FhlTz4P~$X_lNqPZ!C;(|4EwaHT<6zKwfk9{r7r;J$^ciJ*0yY{=-T&p*PSy=f20laMsQ@
zlvp->m93efAtBz_paP1^76eDkB!LA^x;L3c&F<}VokIj+>TZk|%wlft^|Dlj@O?+%7trAaK%r-A}bzx_!PWc
zGJ+|m*I8v3?7qEAi#hcuTysedl-SR%iwn5-TL2+
zjg5@Ro9s(G7icOVMA6Kf_B}YiI-l-MCS&AoqxR
zvPYPE4;2@`e}{Weah!J;U8LiEGJd|${zs8m5ol0u;!xoLhg|+03W_@_|35y&A;t-k
z5-k8;7?DKw7{fOC#xZD#VXH&%
z#QzceEqN7{?*LdcGh{EwvuYxO!$-id;?*@BtYb&``wX@f4JjOc@u)B{XCcnnvF;2K
zmJ+xcmi5)BtW*?fe-`M7D9M=3#h^ZpUKGlA9<3)sRyN9Z^8|_pWcp4l!R5qu
zpwVE%E*@;ns*J(9aF+lQkpV`G9r?aBpk3F(#X&$2EO6@4jeAx)8wCwFPfBFLo66ct>#Bk3S<+3R@A2-{;f!k>I?LbShq7Yf?0`L#_6a|SLZ`jjw
z`&P^ks7ycD#>_22deY@aD3Gwta~SKOI&${ImQ4A_90EeT^Oe%msz^m`C&TXK5WnJ&
zlQ2HU7!=OA&GIVvo=nGeJv5K0zK1y#aN$b7`UPLdb@+);DDA6$wsYR-iSWS-Szf4c
z#&+{Tny3x^=NnLm5DsWmh$>8$v9bbV`h!q1=s0a1K(k;k^LR6>&jVYgYL5);ltGl`
zg85mWwGLbN4nP_g5I$5aMM`8x;YKsKAw|wB4^rkf^=$xGGsc{_!uI7`C9j916{B?A
zG4Pj*Nz!~%m))mr)!^IqfrgrZ)VJA8$HOQ#BEJ%NVED544uz%dt~OhM;P>hWWRdZSh<520jfzw;du(uMQpRdMTmZP%8f*Pr
zB{`-Gyt^<2INx;4?VCt-Fim6=WGS)$=6Xn=K0O3jzg=uo=o5;^F@L|O->goYUoYL;
zJbQ=JV%<5@><|jVK5)kdy~R)EjE+*RK%#1B06qpGRmePOmmY){K2FfHR7Yxoyo1g){OzTOii!#(
zGB=%7EjknOK*|BY9cEn$RgQ
z%*M)FcB{
zd?JHy#l@JDdeh@q>(PwpJlRywkPGV0#AZ|QwjW_j4a5v~^0dp_OI#W^-_PQv+x|
zNX;=eel&E;G+cDpQGKPYtsHs^fN|6@;R5KTo7VG!zi+&45e|pQyeY9k!K0HpkOBdd
z1n1jArY3pV=!0e3;3zlIT$LD|pl6XvP^vi63_u|VX+3=FJpGbv9f|``5G!uN_2#=d
z8cbY0CKRA&vVO~&UWL6E!hKmJwY7y)v-+;3wwwlsC|;i-(v!~VZh&pDx0i)mEIu@j
z6!pjSfy#zS{09-#lO<21bq$hC7--Pap2fj(>4Z6C@yGe6fO~x57~H<@YuB>&v#x1@
z$u4X2Tg2(pjk2$%0g%9e0M%99ck?NMtX;p3JxYdv1O
zYzeG8EAYkgjpc&(kOGP#By>n?QJltw$>jjx)4?tz(ITsLNyM&+Nt3)$nkI)1H^VZu
zTFH&?{U}nXqDM*z6<#vKcpIyv5N?W|Va$P^1|QS0G{l?451q90mr|^R$i4*1iTuj#
zr2dL0-Sp~m_btXY;Vu|x4I$PnU`#%M4;A2=hg&spGeua}nj(zWf(z<>rI`i}yLit%U|A$Uch=U7c!az^)H1ZT*^R`JUH3mNsRVB!G+B&?tx74!_1&{h_s<2p{?D
zcxBP=cTq={z^B$2bX(Y*x^Bn|<&xJMy>qT)_);t)`>4j1?09G|Adf}d-bX5E-vrVD
zNfK7Scx`XI$Od{W-t@qR(*zfqqLE5_w`DbhLeYkX8Qk^T-;4Ysahfd=^
zO->0$qEJqzzw>vv_Nn#EB*y2i52DRMEc0>U%quQ&PZhIu)%Oozp0xWnq7r~J--E1(
za6UPMDc+X%yAVE1hC=*3h(?c}agZNT9L~D=TI?X`T3LI{M6d-F@BX3?T*AL%6|>OW
zO9ppmmSN#W9rpoAfkdb;g2`m$;sz`
z&K7$~niydr=(UFLGDdI+A5vfq_XTREOU=k8ILTyC7ZL+PWIWa3Z)fp8Ldg5d%e{Vc
z*1V@6`7XN5ZZfKUdgOCgfle+pfoO63WgEdqT?0)%MVzT$uzn1$Ty010l6|CfxtaIK@CwljUhVNm3
zTj-eMOcDd9M(QF5sg_;^P9lL@yZ+Rdqxj2w3r1?
zKiIfsYz4Sv=63^kmNrl2QySHW%-X
zX{_pB6=*HE)BMzkXC_eU*Jss9h-XsD2+>2TGHNt~hsZb2Azh#Hr0!iMSC||1;I&&Bh(~RGg;NJ%EY{LA7aX^S{w2H^1
zO}EsVKzDP=wq6r@<*URpOGlQCbG0mrmR+5omp(`$c&JFkINYEdy^~Gs7%z0t~Sq
z+RIM@Sgfe5ls(aUk5bQB^ZfX?zX#{6%&m@ptyemirAWv-Zx=-05Ztn_Q_WcCJW#9g
zm*RVJ^saUz1&uEtQ36y1hT6cz-O;a2?{bK*0>Qid&A|7YG*9+=Lo9;pTC7fsA3XlL
zruOn{Qq4x4sy R)997ecd8Ysw%R?=k%PX1C2k-jQp24>D4H!+^%%Wn>yS|61H@v
ztm5p_-^gY3rN$NhmXgul5ojde8ihqcR535Lkqir3LErgKdd7HxpBNt3530H`
zeawh_&_3Pqqn(ZWldsH$b-@u5eTF+dUqmlY-v-v7w}sN?GF`d5mS-I@{dnd8RRX5f
zZN{Fv;@1-)_KqzijET{Hjen1fXU9u(9CL%4N4uXT@TA(kt=fuV`v?3{0T;FPkik@U
z^J$roZm^jm0s%S%30)S`>V(&k2hQzGtB&k7Gkree~n4s*qB#&8Ajj*as7#rm-h8{HeB>h
z8Gz-=!Q4dIY*Xuv)p(LFP@{t8akBZn9Z!nIi!^0&yWAk*26D>$=!UB3G^_j9=pLOu
z;bNBJ$V^scD)HV6tGO!bHLe=h*StqL2s^^By*Wo2Oz?~guntrdM)D&Sx~_D8dJSOFc(3981M&IrxjHAo6d35MnVcJomL`!k?UK
zn9Am^;p?pmXE2!*{b}6PJ@U702%Q;7y#r&br(ffR4RJxiV9KzM?PomMYF%Y+DbY5!
zJj}tH>~DUx+az<$=S{gwZxO?l2e%vWba55lk)6FTRtUvaFS>RXMt8y)+cSMtW
z&9Eoaa4(5EL)4b>)HpB#fc(tW57jEVw@RLoik_%@9Na3OWm%{n=b=L{8Lgfvcp>bx
zXOOC~nHT%Tjl*d1TS+Uo
znx4kc4|`%On>EfgD?K<_w7Y}zaoi$(Nsht|#>vx6jaC;oUmnde8aCViRVXu6Qb@rq
zN4eb)V{GxQx#~SWQs)KAOQOPWU
zpti}f9yIf8Fn6JI8t9n*Un|P3&~(4;f*=cDwjyRg=W~ULy?bAzEqo3RraOAa+R{pZ
z7Hhb^4_s??Z)f|O
z;`Di#i|xu*%UsJ`AhXT>`LgrHe>9vaLfrqv_!DtVUbckSfoQPwhD^H6Sa$_hS;S7l
zn^h&rNL_sry9jeNmM}~zH_F5OBd10#Ieo)4i2?2>00bzslpM#uy$}^We!5Pm9dn(2
z<|hDsi78MVP`>Or5BY*?n|-9RF1_O&lHliCwn$twx)ktNk8ZX0mxK1V>{GN~KuOc|
zv98oJ4UBylb9}YcgXKh~*=&Shv)b!NQAbrNT5e^%w%+wWNAiP5JCEih6cVv?=UmLl
z@3f^TdN4B>J9UGfgI22Q-spy2TFzgVVKBPqvF(
zhF*3_yn7K}!R*3@R?a4c+uiETN4n2@bNP4g
z;Ey(IaG3x-_k{aWn;0VvsPQV6j~joT0bi}`xJ^K|(3vjpM&4k{%V$=Xf`|>bJ`s@7
zMR#av87|#nY9;;dF!W;X2d9$oPGD<{8$+MfrUUfRUA3PnIejksR3;{19b>RWS2#rR
zhRAot$O=q{_YaTq^y7DSwD4Gb
z^IYxF8x+`YTtOf)k$6wNUtdErTbZLcdT%cLQrW@Dl&_asLsIDrVJuMk&Ixez5(lw{
zAC#HLZ_kv+d%*}QFs%htVa;ARaVH}qqn=|m0$_;GOAdv%;KoPp!U?^DGlnXcC(XbX
zAwRPAP}K|=iiwQ5J
ziM?;n9mm_kfLDll+}?xv?yHb6WjA(cQ;@v5EBf8@p`r57GmsTw3>=CaEE>A|{E}y{
zzDj$s!0G$ojY{EZXIRSjX2BL(F`;l8*&&QU_ccb67K_AR)0Q;Uy;F$}1khA9c;6Qw
zpizYgrmbnLo24{(Cvy!sp
zV}GULlZmVXXI4^=-bP3Tx$$@v4fKA4mVqQAE8|^nM5Nb285QGA>mHHZ;x+@=w$Qa_
zilGCK3EyL^n2ToD{dkBi&XZ*m~>onMs111d!
z0wll}uqp}%oB{WRZ&VA_onQ}$h7cA!;+uIk=IQT~ZA;HX!gfHoWt)gi90*w1vn5nv-qoBsg6+HjcEfpZnB1U|rr)F%{FKH_Uh
zTfsWa?2;hVgBMM?Kp}0k0SS(}Tboh~2_d|~Mpt6UcLbOi27#J_1M#BT=Ay`bxsFGW
zy;~8$8f?2xpC6TLvuz4@h5~%d<5$WBT7&M>wFXfVpuSJtGVZ-au~EKfgNByo^hRKO
z>CQQF2yq;-0z0>218s)$Rs){sx((5bO8X05rT|p!M``j?NXPtO)=c&(r
z$Y`K=?8al%c$rg5k8_8Ws`R)66;T+Rz;80Ll^`ei0n+cbV+^AyAX+MJxjE}C{8yv3U`EPsu
zr#o|l1eoUX;S6jy;LJjs-@P6*a2xUAn-
z3B$!*@rr9-=f8)?;ONnkjQw1#=rYC!9?Jyz>i$eqmE2;%#xN0nq;_gR)mw(TLCL#V
zf+z%>Zyua{tR+V6Be0Xo0x4|vB4h~)2Rct*mg{6)je|azS-L>}oI9m0UGgxfj7Q#G
zhI8qCs@vt%Uq90;Rd(xT|8)Oh`LWAZn+Vf;TopR=$F`|m)x-VHj!BIJDT_nKZ$gP#
zL6=d7Xgz6oh|4Q)fn{s>JM(rUHA@^~bUe7^Xz;
z)!dz8-+u2@b!#dI)&m?>Ju7ALHUmRZn10??-Kog;W*mm+O3h}q_BPl~5&X$%bG0%l{RizC#+B0H
zLG`0LWLpY=ZYG|Zxv(W~s_V@t%q^6YC^I&ldGkby>y6d-L1(|jyV~a%K)unG3OYS!
z_p6wwP%bN3OCcJ2eJcKBuqZ^FY!Vlg0$2wHKb4?Mf7sr9w-byGlV%MHz?lm2T5hcs
zd)?(N?}&Mv%=!sVkKUI@huUACn%E3y^oLo!q}h9&KvmC2ag=nTAOCI%;LBz6W|qJS
z2Y}vuR|WM4x`UuCP*DVGNdW+=485qk(7%I7^@`+?;mr;G-oPFB;8dxvqB7Nwzim=@
zY-sBmr>Z)3wz7Ab(7yt2bMM12<84wy7j9|0Dg6xj#E;D($;Y$D$U
zwjk)=I7(ik0(S{-1NIGF7%FLAH)h>!qeKJta6XT(KK6!3=}@$~5o~MxJi7u4-ae*4
zoz@m(OWghNe^@~3mHa3Z8;(j(!6XQQ_8O?TEq;Te7FI`p3||?K0DBUWumX!cq@vc@
z)1nhZpvNLM_*i;feZH`=>fQ7#_oQD51(T
z7FyPT_q)L(8{N#%8u0rZ$Qyw*s&H>u7LFX^=+(iK9
zR2(D`^Y;FJdaAehD|HcHfb3IA^0H!aa}
zaMq>0q|;nDilVXnTk-Df&|UYJrrAV_IAShdU3C%*MzO9NA;g3@a=^|t&$;Jc@9Yib
zy*_r>R+mt+ffEi(2*@B9B>5sfI%KUx!sD@=eve$!Cp7&KG)3~Y++>a+)W1MUCLR@z
z{S4zag{A*>g2+SgJHrQ|-g*&1jCx9&U^cDu&)q(Ye)y=Ebn@CN1~4
zyG9`Gz^*k2D}B7YC+6mA-Kvl4?cM}b+*oBrSlsDrN?t==+<$ri=pJ+x+)pUq4aV;0
zfy(4a*o8DxB2ISly-4cSJRDxU?$VWanM~SpK+H`dlWD1_v~A)g%;zu<4m^z6>bOod
z)aCml7C-l}C4wpiu}^l2KYS;$mf{vg>j&t0N+HqyY&03*{{yFF9==Wf9FV1!;Ij8y
zZCRc{Q(0;Oy3h!}ajD@nxsdn|=g2D_fbx4U(>lu8?QGmv;byU@M{y9&1nj7xFVHhP5-`kaNP=l$97
z5BaRb8cHA=yt=I<8M0h|m|JD(MaK>ym;XWyILJWLx?}OD_N*@)|AJ7TotnN1;W$Zo
zkD-B*=JUdS(&>xo7C|d9)7S8&QWe=!cM243zqfSd2`bWH1fLs(VSB6&C!N2
z7sWk#)bgHf=sufzMUWx0*l&APIKd2R8QZji8@zLM+_i|4M%6OmVmfooSQnqk!IrG`-^OeOD62
z!!-2I-)V}M4E(xnQt$nR`ekHyd-T5ic8Jkc+VnM7iU)wD)-;3TWD~tS?TT#olT?+W
zTcO^Gt!+G$uY2hB2N&k7$hEU43nZUND9ank6=Xe+Fn*KCYv|HSue0W4cVvMvf40WU
zmVv48sZ~j(z4_%ko58=jOlFoV2YnG#Ksmd~f9pVQ&;>@`tbT7t7Pjrm#C;0nBS}>q
zpRQMkj|ABV{gzFY(fY}=hx6*Cz`{Jh(P)BkRUmAC|F#Zv66cjEh^Ff=;vdCSX7(3Z
zIoq9PcLCo!e>)z_)Z2TxnDqCh(c53_eI|u3Gy7+GReEm>>qA76+V&?prg-*ld)J=9
zxGU(J?m_Z@7~iy921lk6$docMO9(LH~M
z_V!FmQ>Eu>tYp*!#ru8fk0Sk}l`W*%;`4nPzFL6i2q%?vJwv^awRl&Lr1}8gu2W=7
zuye1*~TZ9CX)o+hHKJUkNFLGO&-j@e%LM9d`@uNlA7epC54
z#pKz+H0DDSfh8PI7KplmF+7-F_9;ZI&vr9ZGXI6B
zez<7e&SxjRe902G@`yKh%Y&&JK8!SLUk*yoUZ`2jH<5|%q2H!@D*yb+4_mK_dCxKsY{7`4Bl3Tz3_;+a;D5Rwl3fGJ#=A#-
z+A;7qb<)1uL#lQM1iNDg`)0_2cb^^U%(dI)Yscnxhh&lZ>U3$M>|$qj2G6?qp@Bg}
zL=Es7iK)F>WIFm-BJcbBwD^l3Pa?)6C}T5s0**o66&k&c_9(n5A24Ht#W2$A#U4`_
zU>aP!u5BJH7tt|NTWoQ=A<2qz6M=VGu>E3uC83D
z<<3;(yU@TUbdCPHLxl+sl=Rsj{zi<6Nc;D#1n-gk$>TH3An>Hoelxd!d2hec>U%3&
z<($_k;6|
zLQEon0+Av<3dI~&W02p--mA6(u&R>9rD!^-^G)gmw?IdKGe^J2g*6!>qUjxoK
z-B+saedv^R>s2wz7+4+e6We1O#`d_Ox>5|pgPkkQaQJEQ@>+PcSeuD8J32Hu~(xg%vAQkZp>?Z)NX8-o>
z2yjfLP%M7{l4PosQPe!q}MqJo<9UH
z3WnP8mL&AD?)~?7DRPZj-vJmB5A~nl#H87MOtb}7_h@!m0h^HW
z?}w4oL-9ie1~$A^z4v*Hn}lllZO1Z8xyRYa&X1@?yU3CdTl%W+>O@xI<%xDlwV}U%
z_lL0Pgo!h%lPzZ0aj|#e9(6H|9z=~G&Z|je
z+qz|sHrHL!Az&#=_MKR;)B0~>vsLTZ7SaJlk9sbJ_JOt#)>)E*C;nXB!GV0fIC&2{
z`+;r4vJ%lM;A9%1i@B=y*3V)~s6+Nf{RGkqCZoog?&d>vgtK6o=oA(!m%u!~6$V*0
zD+ejHoJ+ST3z~mY($S5c*n!88F(G^gzl6B63j-^54k176){GDDufcl`-$2B8w|u
z`-DP{aNaKhq=f@{DebVr5xX*h+~ucB9YSn6Ra&`x0b+Y=Bi1LhZyyt$StR2XdA;X{
zfq&0$T(>rN_@|oi9O>VG3RtWCRv{Od%0WKGHimCaSG?TjZk2hoYOArr+ESGahgsCS
z|4L@V$=eiIP4_8GlnTbcczN>qf1+iPOKmU^)@g%7i8DXjVh-am=)`pE^H}q-)qA~G
zw(TBIYLpoK2Xg>F4P@l~(2EX!Wo_BBcFJu4HwWZOvEE^X>USB-0Ip@4Tny_3bqEUL
zrYfaf(s59c&_PKfaHp{^kg^|N1t0DD-C&gAlmyFVkE5ooqdOzbD*pp>qI58ZEz_4d
zeZ)C=bOVnDE_fR-V=lwm(u`}?T^Yh)Xz_M#U06m@m9DcIGDp@5R
za|fuTHQ3CIFQTkl=Gc@2M{NLK4S}XKX^MvV|F8hMXwkp|oOev|e}VNvcb|-u8{inR
z6kW-R&L$^#`?8}%Z$ljj%JD8XA{^NAq)&HteL^ilu7$5i?uGhY-h1X!;@%L8{7bc-
zJR~qZYF|fA%~#A$_~`#5LWX9#sp>HayjAjjBiJ9->CMTbNgx&@jF)*O}AZ-0X0UmuN53Uc>fR^iOjwQ5VInU7pz~Ko!;dSgS
z35~E`RUx@3Ozj$sWa}q=4Bb%?F&-(ge~0SNWkZ7PAk?3;_|6>iv7L&>WzNKZLiJA^
z-jSf#joObttTU|AZP!*dCTZTwJd#uBeT&=!pfjrG5gm^IW=wld;k|&+S%VpsV7I<%
zgry?q7s8LKZ-Q|}FNU?v)N&7adoRPL2Uz}c@UG@zAV`49<^lE)(c{lkuiMH2nsfRM
zEDFlQjfYqI@Da2C(2>a?5Etkw9!1sT93*0SNzRA%+8yTt6O|tjYzT&9rvj
ze-E6`o^nGBtKxO@$Um0o6gb;Vd^UOL)&D|2)rK*=LFj+nN|)R=vX0yXsPJ^jyip(}
z0RQ5MYQc2qu~pWpsEM>z=qdjzMdyEgLxs7lt{Hvm;#9X{-VR`Iu-v_1BJO@7U+lp$
zh1VHVPu!OS<_Skg3K)Jv0iID}v&cEqIXGqn2g_Xt>dPQuQClY4@L0S7!-Br|{p~ak
z5kMghD+dXySIyi+YVjL~PfLIi?8a?5{N`KzoOI&P5a)ihxha`2x6M>gyQJYiztZbT
z!K0|gl^Ums;oAWpE7eY+v!s(WGo0>`=n}YhgnjkJ^OQT=;MR{#F4qY=cWO5SiOA7Y
z7q+7`#VC~(y~t3{G)lt7PErxAKNwC-2HqVnx+d21r2Z31Lc-sd$i#^fxyPq14|?5S7%^Kgsj=8{|1E%
zt(%N5w#z%26mR0$wejCm>|if@Uxc10UAl1RUHJBGG>5p(AbbZ~2|U8`%r>GHL~~#;
zr55?za06KG!DMoV7;g2O4p#=N2)VV&>%n!*;GbopU-1J)5m`I=rRd=>zsL$MEyEQr
z`=q+;QFC0LH5D342Q?{_NJp&OOIn08Ux&eSE!#AkCsf|0Ge=YjSMl^w?ZHeRIJkJ_
zJmh=jL$xu)_K$19q%8j6dDPyKeuLL{>@f;YVxv)`mEE_Man}8R;cBbTB(lT>x^z~A
zDvT8L76!;0T<8T7nM`GKAdB%k_lm_OopwPh`37{LTZ4cErW(
z8fUxA`ER1VzYyFQ`A7P|GMKVx=i`{eTv47eBQpdAMx9gd3#fj`9{Bg6s@Jpee@2dY
zE+F{+;Akegk5@4#Z)>pgG^H}8^gKn6%Yg2#F2L`IBvz9Uq7x!CIW63JgLvfH|6G7>
z15av10sQ>9nNQ)4a`LO`RNFcH~w5*Lr*=_m%|a{TFmHW+J(%R`#X#RvNzb|Gh_WBv`1DY7<&_F;bg
zL@&nF@HEugzvwEe^7t-@WKv#vCBk70&Q&?W5GTrSUv_S`XZ1SePWta*F6ONEo+8481$Xh4>}{eA
z(g|@r<=#P}d&>T_{Xi%qWjWcc(Zo|`4#3m+5eCpcMTVt<&}Q8biz6pYn~0>t
zfi;xPQaJxHbf5XUAzU*V1K7tv$#!wA&EW1BwQx?`?a(FEu*b9>lSnhB_%{{=(^Gw-LGHxG*HL&{
zMG9tn3TDgjQ#r)tw$ou_<-a06Y|~#CZsw{9ywD!}TiVC;B1#BG2v#g1M1s05
zo)CnatsTRx1j<>6i-T&)KkTdZi#Q=l3zsR>WWDcV3MrSdbPWI3%gfKW1+!wdr&BVe
z=~$R9T^^o^x6pWg@SYV=CfO`a{ajP2=9=y&_8n$!!jL!DcNH
z|Fc*L`P!B{E52_D-*pUEsQho<%VboqAdDbJ60t-g$AAAgILy`d`P@sILO;xj0R@j*
zYhCP5KKpOF2PMP)s%QQ2S6OtbM3h)fB}_Qagy_zuvF})exuR-0u=d=W*ZnSGlbx6K7$&bHA%~AD^ju5H=#G3O2v(sAw+RNJA)^QnD)@N*FWOc
z*FDT0j^Im!5n*ie5+pW=u0Y1&eghEJIMpwdK0@42ELcA`MzuB(^yh_u(7~0sj{yIVNH~H;3qI4w~-QO@8VUroNHo2?izX57!Xq)^_R@R#AFw2Y5
z4^}X072$`Clkk_WBXjul^%Vzqz>O|8kvK&8h6TrPjgcs=Bd`@NJqSQbRmXY&HO6ek
zT?JDu;S1}ig~ZKbmpv0O!u3H|FOxd-7u`*&Si!w7S)P92CZx@E8^{y;;d#xanNElM
zlNy|UfW7wqe_NM*05oC(HNy>eCtCOOR`Z
zjDX(28xhb&Y$7qy=~7vt%Vl|Vu?-M91C*L`gb+N_%&euql!g{a_UTLT}6|9`^JFl8J3+$}i`J7`h
z((@s(3gU7lxg7Vp-$VfF>mQL;U|D+rCQh10M^c}0ecrlKXZNpU2>1{>iM(yxA@mPr
z&gg&#r1!?bV@FBGd~FN$~5mHmgWu`?BuxQ>CYdB^i+d2NT567gjTu$#L
zfBolNN@E2c>O3k|-JAUTk)R%Y9?khE_I}_QF$V~MECtujnK-;R#wB|S_V#|C@G?4W+O2;bY4xz
zgGSts$|Gm$gJ*(V?ms%1;T!LEv*@hF2?
zPo8Db?5eqXWb&~ErVK9)OLs5PFE2N@t~B`G9uq1_v@ffghVfHmk8yVg0zH!j|t))JXyalVf7##Klvx%v^xN<89QHA`?lfkVkYdL|nORMw^m
z57THT;z7!rm*q2YWqQ-jdKQmEp-f07JWTmU9>RXPCtBMY$WCe*Fu$mFl>tZ|T3VFaujydUaHU-_gH1
zdv6aY{k|h+FR;4q1xRUeKY2{n%4BsBBkWr0q^%cysM8x@bb@5LhOu7_oJvlcMDpK~
z(yMrg^856@^_)_C3;JNdV`Oj5j9POl#ud1N4(oZnbgbeWNm=O!
z9~zV$rkQSiaLGda2UZgSUxs^OhAtlMH!r?8`8wNlKjk9~K~JWu+iLxU-Zy
zhs7ih^}KG0G%89IQOZjEH$O=k4E7JikH613==7ZcJynTBY4bdxa0ovzyE&q^vj%wd
z3O9Mr5xn3TvZXH1P-lTCkwZciYF&8RdhiCZnO&p#E`**HHcZs)!OftA#_0DjDOR$;@iAuy78W8E{5er4AvU>0o_
zFDlzZJ{Z?nzFMijIiI>oPA#uHf^T^i&8Q_&KGZOI6zsruJ&rSX?Jkp?TtOvuNl=@b;qscY$wvB?ymXanB*`VtEs|$eo-$iLqnJQUY56
z1W1I>vD;`6O-G450
z^C=o$74ytf)d9*O!qx5CsNuWdG(noAAYS`h^5jb*3$@5Bn30I`2rl^0Fd5--ujJC;
zK`+M4QAer7MX{!1Rf;Nf#>%GuIWTg>fmxGACW7jvaprey(uHWTII}q`kjY`=-*w$?
zCZm9$z`#w+fCEU2t3P}A$Slj@_i1#Ax-a>^0PPqmN@qQzm8M7dy|VGlim-YrT%lW3
z$CWZAR<9_h&KQXqO@bv3R;d2%Fo)n49p1BG(S(GCL6z>dcq_VU^2C6FRtDn+7);$m
z0%FE@xWqmvGZte09_zt;lRKImfv7bW7EK5i3ByJi5tD^Zt{pGHZ7x##sVnDQFI=bS
z%gSk20DUFYXW9pR5{%Jc$eam2&M2v(k2FipVcNLcW{~D%;0Zli@C8r8~F(Bez(epzW6hvjy$t0ap;#9l}}r
z$M6b!gkB4$jN%~Bmt}*{!XaoaQ)wYBwfv5lZBd`Oep9cSx*%=WYx{kG2IXV8L^t2W
z&fJfGiHHOrC`XuQhU7EUbyC0}dZqvSjm9LuftEdTaFWJqUHjO`fs|4y2
ze_it8<~E~q-nUZg1P;yMCbaQFtRKIj3u9lR3MJ1m_`nyiUSO$X4BoIxI3SxXbH#aY
zhk3O4)S9MD`lxhqr;wY7&N}9X4Yy?JcjUv`PXXC;+`XKWYgH7(P-
zG*t!w8yvz!hg`LXD$wHpXT$OQPF$3>A$a??ArXJUbRRcr?iBND-i1}jw2_yCqd^MN
z3^B;yC{_1YaghQg$cGd6C*BkS14^QMe?X
zWHC~>1wFd`>9^k}D_;ze;~+#;K|B1gQ=d)$zpsHiU{@G@_3EX;htN;GId_>aZwI=B
zUJeG!E{5FThmE+wPQ(OMBu?)AQ)$gi)vvVlXVl)?_9PsXGCEf7FOfV-NhjIAa7QFU
z+*a~YvPw-)3+_S`AGtNM7%^i+oxoJx8Y>_1aQ63>b0!z6->W^)EltUgZf6OPoClw7
zxWoDv*3`?4luF#yj`sr(bLE>KZl<3sN}J_5{%so+6Ca7#>PMnveId-?+1sxKs>-We1_hIsFPt0uVk%>@nGxB7ukcFaI?*GsRGLj;os_ij!LEpk
z^2i?lOIXA{X<oz}!!#f-
z{X^We`J9QS$Qn;oxWGQ_4-y}mS5^?%n1Xbq<{FTeM+O17j>h}8URkPDFH9!i@TyZv
z#Cm}fY4*;4a|0DN$MihrO*Lm!xf}lJ7^Z#_V6^~tT-;c`LnKx3XYl;-z0DZ3JSVSw
zzhoM$z6ndz?H{bewy{J^BIbJV#C{6mpFHJZAo%g6cZHx9+fslw;TBS~8QVu~jq^mBaFgM(QXCKisepv|2mjMJe$GTE|UR)j}YFM7$+7pO5$(0@eqN
z-Z)p?n3-HY!qyR}yhS13J|>JhYpJJj|q>K!38dPON%6BJ!K
ziL3|ScvA0B6)N(iXn_sOcYb$z1f!_@LI^pbeBsZ;{#WqD%tCp36LM
z{+Xj584P{W0j-iK>k1+BSoSYXb>IDxv#z@V!ZPhfEElja{hsBRu+n^TKRLvW`%M?u
zvd$`3&wimyqO6P{rep9LE6v8e_&kX~BZl3&q`1$hK9W6Zsz~WOy4iU$_JMNcm?9Fd
zL+(3x_avuc`~7sJz=)RhX_Zg^x1Z3&f2}rD@t%3K9ud90{VcJZ?th0Y;O37H_a>-a
zdU=XZ_kkF_{mp8I&O!pO58u{j%%0H%g5p9!sgzV{6)p<{aNxRH<3D^227?bcK$suC
zofXLVeB)kXSWs4zdIq6UNXj999+s|en5R-60{*B+u^R!&9o4~He^cXHN^7Hr+ja>S
z%>Y<5d*ED-YYP330>2o%Zu2utYFcyih!uyF!fJifFWoJ9xk^8n7ugtSe(`@)@c++YnzbNAJIa2Y!DP
z$6Zicw&X7Hma(hJr*;_(-0eel{c-Rd!&7UJ$b^UZ#F<{bY~U5@6<~E(NG*c!D_OZ+
zzRC165_!6Rp)o4TIu_SMNQe>Lh-8m*cYH~NB*Gk8AY
zew~BI8NVY;W~ke_s7UDzfCJ`-s|&w^`gPBz{iP3PE}Am6HVji})JsM;V7xh#W*YH7|ol3Zfo`&K=P#
zaulTDGC3P8TgY>U&Xcg#YSuKT-HH~No17q7z7wmuS3-42N!qfr^oG;^wxQ)*Q&A~l29h=VwrjH&7&gObzDNs5nbV^$TYk_UWI
zm3znSqg&=1`Ms|2-|@Lh|5n31nbb)5d8}nDXQP}~A-$0;jV`Z>2$%53xud4w$sXB+
z9?JLYiR66MfSBo`!Wd(T4{~
zuGs_|wDaXQ`g>VTJVS~ivp)D8)}zJo$Ie0HY)IVHx%^tC4AlJqE|3h1NPpzMu{)$2
zS4*?aN6AU~N_bm3v5Xvl{j@(iTJLk(`J+LZq>7}C7XCuq0?+K|
z+3-2qa*Iz{0BQVkE05^OBb2%GnYC06vOK+M;gm(VyE)$u!KX
zud+WxyxqqrxJG~CnGb?PWPIlAYfmzhOQ>)rxD4+XdJ~FHC?cZ6UF!I{h>7W_^W-s%
zI-d`=|4M7x-^aJ4lG~Y8rOA=l`kAVf+jmB==}bUr;XaC=5_&7v>X{ME&Y{d_@j
z^H9yHLJM*}TIx=Mcr`!0X8E6?4>|&a))xXYihw>4wWv2E^B!l+drGkoh5Uv-RK&li
zVpFb2I_k@Fclt)~84nvJ4_}{d3`p0X)BA4S@gUK&&V@lMbq$p6v!U)ROr!k4MEG|%D6Aey!0=VlSLA7zb40I;gC+E7xY8Q|6}ifnBWXrr-vl0u&Dr`{
zT#v}H4zaJD;*KTLJQhlREQ+yUNGYeva(??*2H905r5nzp*|QZR^ja>|4v~KqpED0E
zR52Zy5$~o;jbiy*JGRdhxJmqC{^FDO|HA^_D7Dm8XxN{GpybcZyOy|Qiq)YkHtk%g
zLd3&MX|KC@?>&9ume&-wD;WmP=YjK;LUT7O6=s8iTB6vzmYuqKhq`H{@W69}Y!K>rE{6&j
z)3#;oIh&R#qokUFKS&2wXwBqYn=fFzY#k;2Uc96puML!J{UN{FyYZRiyC&EEknvMa
zZ4AhS)6&!A9vI;gmL-!C4UFoc%9=2gUeFTQo%gKSN-SPv^%isEuRx)Zo7&x;mGln>
z##}^#+8**sMSVBu&Cul~lt)Hn=hWphciV^>=*o@WP-M~=^z}JhJ~Xe9j%535>JL&I
zom_19)md*JbG*C{+!stJRzy<@%&U2wtf3LA|w{$
zsa9GqIkEpX+%ID@?>or!7+tLv$yb)^jtBapSDlV~5SyE4+T44-IBz??Eo7JPB(9wo
z-|s;fc1DgD?LWnrDmqOBPn9?y{|N7|F8`3C&-bmyf%}!b_Fx>n`*9~-
zQvV4)&n9~P6OVQ!Z>}2cvq*nIFKK=Mgqb}ICG+DA0!o=2yQOnc`aQ9wB=Z_QnvzT!
z(s~zi*G|&*uHE&^W1j~=9bTO-9>oxRQ)wC^sKjtSo59DoJ)29jz(H(LtXT21B{LEp
zTmh|btCgs$JDYki=3~UNHp64<&l###Tpe~*$qUr-QujJ;CCZoW()alLGb+SbWlC2Q
zCIrFkOBvjYu%=XV6nPaC@!DRpX-@*&kj-lxzhb+1un0lml3z>4o{w6lCS))lxn-AGnt;F(=R`GkE
zhLmizOx;Z+@#PiuZq!oe=lW^ck|T9>`~rs*w+w3
z-$8qXwOR5`qnC568P=rd0ns}r&e>?ZN^*NwZ?S11MqFJ@dRSB}&(6z7^CutAQL+>g
z+~Z}LXR!CXapzlj8&9A?#d@IQXSF@j=gkw@u(^ec?A4o1t2E9+
zL%Hyp{7&V>Q&k<&ayw~)mI(GKDM{D3-$Tc#N9Ge3Otm(}-lh3!eHFn>s&4V5T>xrL
zPLRKE*qFb!?+F-+L^i&_adfdtwV@d*g_)EE&Wq9FTLE}XAHGwYeg8FOAcAhsxICP%
zSMLf=96B#=qG(eVP|M@jIPtq<3q_24zrR*`Wag@X+qP-mjdLF2k2UTw*v6J4#
zVE+eN;2hikY;&x?_p`Fx&BH1AkkK!E6BVHW>B9F~p>yA{PfEO;%!o{cqRa524X|Gm
z&w!wOwYMfAeV*28zn$yB{MmJ_{oeP|u3uI$W~~=+DStZbX>&hwP8Eo7myaSy^l_ot0dL-uJ~3>
zn#S}4^=;xYj5Fh3pSPg4;9A)64sT4~+UFiMxxJrKir8>En^}TG-OEh2JqIjmk)uI;
zzb1c@n1}O21O5$6`&A0*y^Wj!bJv2&V!p_e^&>>q;l6j=%m#nh&7&giCQ!orYYrq-
z_}#if>&|J!uo}}x+3W?S4B!XLBd4NYUCu0sRQ{!<%4M+k$hU;P<+9|HUIAbe13mIK
zQa_jKGR9h#aK?t|a>=x>CDjzYIdgr7T!KrO@R(ZgPr@Xjn7q_~xH(_=Fa28F;*DF<
zQ(9^!)my8})>`~GDvgopLfP>khAh;kRC!j?8`-i1l=@ow3Wr={w|BZw>)VkV^IHcP
z1sRIdi`F|MhHCbyrs7frmUFBFffwpPh!qZ*DCeAlBRgIzCGhr;uoIN6_9_5L$k;SDfM~|m4izcIeRZO?k~R(K|gxcOqG)%Wqa~y!0iQ=T*uI`
zfM2dg4>~xNj)=auH{KD{qDGe)vZLrwGX49uVwx~lLL05?!bDA$5F?sud0^XFn%S^-!sbWYcl>d$-
zQbixHMM+hsr&qZLaVCaDeyZ9M$+Pc}fSj0zU*ypdeV%!7#tzO!W~zomx0*1Caky4`
zH3?1cJR+4xZpV6>S~8f%fbZ6zir!T#zDBizPe-nM)(tM79oy%3iC(TUUB7hsDVa1)
z#H0bUwP0Nx0N}?bp*wNYmEJn$%o|2`aJx_cr8cHBp@w71nFq6_#hu+J*Uz7Pv`*ph
z@Q?2!`a@z}XOwW?(2sG(sM@Z5i=JmG_mW?9RYdm9@$hZVOQ8%5EH0YczgKh@eTZF;
z;0yP-uFuwJSfFTEvxBz%9cgWHRo@@A-@69uvsp_#dM_7~Ch@3U%uqJTDj%&}qS)1V
zux~tr>4A0%!}qX_492UTM91lQZMql`@C$}GBGx#bz2jT6(1EsYqy3a}Nt)WvJyj;R
zybtvi5-N9XjB*t`fo9`GM!
z%wc%WRmh=K>u`?Rnw?o5BD8&hZ#cN53E0?H7a9z4algtml@B!r@mjbacxvlr%H5BX%k@_*t-8QYqehMj~WR=ky(G!FX&CM?vt@YvkwB*Tcm%U+nz^h
z8Zpv-WdZNmGu$&YM?v$c0s;Vax3=tgrTHsxTg~}>KPo&T%DGz`lxH|VRmTQ
zRc5I#mG(8$yhu~gNuySCv^P!Hb@{}#`6lIL`Zpd!D;k_vkEv3T7jSi`6>Q{|$m^RW
zI#H7{@A({NX~g%O%rYq`UnApa^nLYvWu&>gr@eGeO>VR8d*AeWdD6p9u$yY}bwE$g$mZ(oX(O%Ff`dCcgQ7>FHH77+
z%cJ1~{0S6mFp|lhj(@&^Hcv3B#3g#955E+YQV8d8EG6lln7o!KZabvJaHEePLVFdBH|OwU4DGLSPY@8Y$P7
z%*D?fKjf&DWhk;~EIgS-lQC)J92U{DH{Tua{$gfqiz^|>PoK)CC&KBs-s5QwGc+c`dn{SdwZ%>M0
zbIwO`#c8I?;oJp_Uh`g)8f@iF--o6({50*nUWV@2i6~%R9tvA2i9yqZNv+j-y)Gbf
zEic**jjY-DdcD7};bX+mCK1x^zzgDTq-e3z$0o5wzzM;VgKwA^87nFSEqQFX-*glD
zOLkWA0gJdU>6i7lDn=`E=OKeGT+wiHx_&*vWv@H`9sc-a*Q>z+D0|5kT$xLdcA>Yg@L
z_#&+K555F^2%NonNo-h1PjqV6Z_aM!xlR0T^+>$=P3#49(J
zhgX~4IumA`kzhYB(de9F=gDavzo@(akF>V{s&en%hAE|#E~TWqk?!tN>5`N#38f{Z
zk#11IK$Mh}4rvfXS{g*@kdAk4J-+YzpKrdIZ{|Dm%y~E-W}m(9ec$W1*0rwix$>ON
zqB4xG9ydXu1r^(a!^iW~o44FIWDCVi(UcCPb@zAo-JDS$s|vhlsTA}{Tr|C6Gf7;X
z8(ShXHN~vUBT|O^p@uG`VL5zBV9(Zuv6CFHDE8}~Bj)BKKa(wF8c9)-dF|8qIDSE@
zw6+yFH^Rr3(j7#6zs}RXMc6Fc7irFadrw09>_uhkKP({kg)4cqnLT;jY4vQto8sCQ@O&ALX>P5}MH0)j2*|+Gf5J!oC
zolVuM6*rnt0A%bmzGE(gHOyph6KsHh@SzCf^88oXyE$wY#|fWY>UXY6TSdPjpvVK!
ztG4#mdHh9r8uw`s?)-16C~Y2SXc1Ae$f7~bumr8H{et!c5>GnjTDF63y|2E&SUYM4
zpQijv`IRrlWq#yR>_W{43UdcNmu9e+7%VuKYdx(`FdyFCqrXE{x0*N^#_bhqBC&vi
zPY*^@#AE5MyocgRaWw?UISa18UVf!>MuK#oIY)$lUZC9tAjdP2Ez+G1Pent~D}hbwEgbFtyY)t>G)Nd_i;I!-8|`XlCcuBF_4&s%CVVF22fU
z3HwsAFU3(NE%ZHTa-(5O@8iEhE&li;(72O7X{DQL5@HOz_5CFDLxv|SdzGQn|60S?
zmAW;MKE2g?fijsc*0QyP(ROc!JpEkm*oQWjl2I}*7ls51?e;kB#~(whk6^W6>r!$|u`qtm=Mcdt46wfS}%;RDOM?d^}w-zUE|lYEcBuBj2*GoD@T
z94vMyKKhNYGnUf{D`mH)3Z!0tTM6JU8P5&8GWmmBO3d`W{&V>{C_QcZPe2{|TF7Y;
z|CX?0jLtP%HT>bD(9yTS*{f1L^FlBC6o=*XnMU2PSyxt^Jfw3c(lOq8ud&X$5hqxG
z_9@8L3~<l;tRHnUC$kiy`NCNH7LH_6A`WY
zM0wzy?Gd`{1XWJhQGvN6cxvyz5j3YKwFaOe6;x9;a%|k8wI{|noc*xG!i?}aBnGd~
z(=bv~*Xenig!X9xkl0BA2ZWI?@j8dXO{Q7;EYAyzITd$m*ensL#;nq>@KtfANkF#T
zryFMw2ZkHAu72{AUWwVlmaG8CNv^~IG21t&)4BmUZnGwyE%+5Ie%;%Iowq-M+hgBS
zoqNVkRKsn&;<@#0cDFn3=NOjbew?P@jED%~lBseQsNFu;k9s?AML<$srcm5^qF?XB
zLmGE@1=B+Q!5q9sN7&k0=M&|~7lym{_&nQM?JhYb+*#>uUpuO+jyc{b4E|$@kB<*j
z8SHm$!;EfukAJa@$h&gw0MW2LcAF6tNx?P0ZKc%3Ay@B$^$SFL(OI;;lRCYJ&d>&u
z*Q8-e#y!}&1UIZxS2UyA##;#ch9TLcJ!>S3*Dc_`ZfDo71FYZ=Lx`{x!YO?YIYKQw
z@LJ2D{68Q2lT`1pv0bUx@Rh@
z=Yd~F@5Io4MXWN$%aXxn@eW4koagjOF4;4X-VT8BcqQywX<T59uN8TIoDYPa&r`$3q+WrC{%LCmjY5<4{URHN3
zax`om&A(7(%x-#E))xD#;!hX~zH4>#qQC%!$U|mbju}TFPoREoQ7DHv&QjR6%~0%L
z%{7AVjLwL!LvpQLqNX?_rHv;WmIS{00v+-tqWv|xbOrmWA*;aWGm2kb8
zYe|RJ;lmB08Dhc6>bpP~aBRkLiPPh#4aI(eN6$Y>DnLJfZIjbsueG7`NyL2t>CzxA
z6oEH-dfou8<@xP)!-}>#HmE*|VhZ$C$?0dlcQ2)@8~N!UI^m4=KujiU3l
zSo5e!X{0GK7sw)40}uoF>1LgjX+(TC?hL)t_tmQ3KWGUR3HuBWXQ@kiF^~lHKR&>>
z&#)$JZ>LoNn;p*qVv(@6`Y4rz$m?r4^bq&}jP)M@Qpyl3he&@!p6CjxcA-;5I7(0i
zxJv54_I}Cml$fM?^tp71DNqmKnbCjq!uZY-l7keIo~!ivV|>Eh@waFSLHEO1i$P{o
zZPDx%xdj5)W@RC(H3kC!V3vL}$b$4(GxYmYMj`0if7j7gUkrnf()zdPTUw;|J)X38
z&)=az_K3?9Uj9ROkwe*>KnQQNZ%m69JFF3IEF*Y$L&6@{<8w0>1%GG&>IKk2OubVmwrYP+jVuBoOSl2t
zrsjJV#^FiMX-2pBMxKSmmBt*2X-;m!J9o8Bgi!_oTQ(u(3OE_UL(rSd!Ut?Otob;$
zpdoxfX6HYM5Nhc3%I71J5Ut3lU*>q6%xi}3#MvMI_A1o{Z3IX)BK)S_v%^Lagu
zPEI>IZn$3XQ^g_H8J~NYFE7aG1<0yQ@K%BJo9__HQntI3D@*6URLJ=_J~
zQ^N}LCP4z&C>$dgJHJLEyMglk7OuPvxw$*-Qv~0aw)}N22q=zwuawz-d(lu?)&cy8
zc?uDp&b7i$w|jyld6!Hsjs;MxPd=S0-*uf^>;zkhO0d)di6@~?)_`Y6>HRj>NoAkw
zUE=jpsMWzu;sW?dLHM-Ko||eeUOkR{VE&WvhP1hn=E$_bczpq!1HW9toL#rvG#6wR
zl`0%dkq(sZ9)_T~CR)R#51oEL+5#F;-Ws8?W)PVA^gojAb^^yIet!Pvrx!&*KfbOR
z^-l6_E5r?9xI{ixc=hhG!M!d}BbJuBq5wGT*09Nj_k5A9!5ptMS2SAoyw+DQ2LzN)lWND|;J@oqT4dhG<$4S!f4
z5B$E$unqfSL375=O5lUe^?_t%0rsE$PI%mxa41wg9=K{F^eb)34%}3ynLse=ZG2D7
zASWWS>FRA;Pp}l2E*otlanA>T0St2{0{w1qZY{Bp8Woa35$e`~2e~z>9fPv^$wj5$
zLSocxLca@6!CfG>Xzn7_eW!~L8(QkNMi8u};
ztRjD;`$PXG5f^ax;wZsNm;>
zPG#=q7Y*+i=<1B)ozeKfqS+rN!f2Q&1q$p>&szK2cITAV!o`xt;1fJZ8%NC@`X%7P
z@Y(2GoPTdRk0rQ;)g!x?Z~@axc9q^IAoN~;t@wLRelVv!MF`04yIUS^%|No!9*{S1
z@8c9vXmsZ}^n~s0x}rcH`sa;@3+;trcu@-4(-wNp3$S<#gipZKM#=DutRpMr+oH_^cc)!M>%+^(rQK&*tRTfk$UV^7V9O
z7Jr0Jf;}v=!6I5oL(j*j<{sNzcuVbdt=BH)ROlVhBSQuw
zBIN~yOfS^HJx_(F4ZCuY!1AlXr2@XQ8$d7b(G(A(MzimQ$t%vYTILxp)__2z0+on}
zCj-BkxeuzZVE|Sv9LUNbk{x#<=M=hs9Jro??n5l!7A6=*pBxI9mWh-It$aaILXw)_m{Z-4B+u2Ot~zBtLwf
z(BoT$;D|tF`MIcMEmICo<+Qp#yD+e@TJI~wer5M2S9m;T;tia2#Gobh6&{ZpW@GJ$
zz~LrJ}E=F2u2c6ZL5atbkVpR+@i4mu_nUQ=7|3@}*@dK9|^kSb$nH
zn_N`3WZ;YwivOmK{eb$MX?R%JEA%pTbSt2-a%f5k8tn>iB5WSqZr>6WKT>S~9vKLHaid-8j*KCa5EY200sfrv|BUUh*o(ABr&it>DVv
zUqL+aH&Fh+{OpgeA8`$MoVExfR9djCG-H}NYbd4zu-p^Z)t7(>No2kzuA?lce?JSy@{nCndGT
zj3=O`9*nFMi~8TMa}|k$h@9NvT=BUJM5sS3s|*MT(AL(5m&?`(3=I4qFBfxzjFQsH
z#9PZkSy@>^LV{Ek4-ao{dD#=lld3)uphwjx{P)7NAy0-f)6*j;V&mhRaJEn@u)Tqoyg=^EyHwiTHJyX{7>_1k=Fc9Ct!0Y1!xh
z68x+%{`i;t`IY~FKkrkTC%lM^iTU{F`z|K6_r=(mrA21v_<
z@$oCSHaP9&6%+zMLONPG50S@HFq5F-ihTj2TtbA%ADSod>G=TXQ0h}5P-Mu-$-&_#
z<0At)6b<*d6gSeKfnM%D(BuODa55X6t4?b4fbXL6X_Rh6+#NmXvYiNC=E8%
zKledI^xO?($B`06Q@dM)nN3O-eH3ddnAq6l(AoiCyZa5CE&S1-$X4;Quvh>TNh=GE
z;E(S>aCsNF8NJR=zOFLeFhaNwfOV4%q2U=^VOSe7GkSm(mqHwc^63Q}x~_cH6BKz^
z$lGv6TZ4!edb0rtipes6KIGa-%{M?M3KB(>C&)SRCZ9QlK12T(2%qe||9lwfI7v>>
zQJ$~|V;HD@z;q*Q6HqQto*Bs)^Fg}c85|QZjZ96?OqWgf$>oZA$JKp-(K;zSOMrzX
z(rD6CcCQiDL~kSk_EwKUY6+}c@TbA8-UJ)L#mvNue9$7GUA;C3gA@8P}0t12mZkK~#FvFG