Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
  alvinfeiandCursor
|
36fd08b52c |
No files matched your search
@@ -32,8 +32,7 @@ English | [中文](README.zh.md)
|
||||
|
||||
## Latest News
|
||||
|
||||
* *<mark>[new]</mark>* 🔥🔥🔥 **[2026-10]**: 📦 **Released [MemHub v1.0.4](https://github.com/Tencent-Hunyuan/Hy-Memory/releases/tag/v1.0.4)** and **[memhub-cli 1.0.5](https://www.npmjs.com/package/memhub-cli/v/1.0.5)**, with a signed macOS desktop app and verified macOS/Linux Runtimes!
|
||||
* *<mark>[new]</mark>* 🔥🔥🔥 **[2026-10]**: 🚀 **Released** **Hy Memory 2.0 (`hy-memory==2.0.4`)** on [PyPI](https://pypi.org/project/hy-memory/2.0.4/) and open-sourced the **Hy-Memory** monorepo together with **[MemHub](memhub/README.md)**!
|
||||
* *<mark>[new]</mark>* 🔥🔥🔥 **[2026-10]**: 🚀 **Released** **Hy Memory 2.0 (`hy-memory==2.0.3`)** on [PyPI](https://pypi.org/project/hy-memory/2.0.3/) and open-sourced the **Hy-Memory** monorepo together with **[MemHub](memhub/README.md)**!
|
||||
* *<mark>[new]</mark>* 🔥🔥🔥 **[2026-10]**: 🚀 **Open-sourced** **[Hy-Memory-30B-A3B](https://huggingface.co/tencent/Hy-Memory-30B-A3B)** on Hugging Face along with its [technical report](https://arxiv.org/abs/2610.22196) on attributed reinforcement learning for long-term memory writing!
|
||||
* *<mark>[new]</mark>* 🔥🔥 **[2026-09]**: 📊 **Released** **[CMB: A Coding Memory Benchmark for Long-Horizon and Interleaved Coding Agents](docs/papers/CMB_A_Coding_Memory_Benchmark_for_Long_Horizon_and_Interleaved_Coding_Agents.pdf)** (submitted to **ICLR 2027**).
|
||||
* *<mark>[new]</mark>* 🔥🔥 **[2026-08]**: 🎉 **Accepted** at **EMNLP 2026**: **[Memory Beyond Recall: A Dual-Process Cognitive Memory System for Self-Evolving LLM Agents](https://arxiv.org/abs/2606.09483)**!
|
||||
|
||||
+1
-2
@@ -32,8 +32,7 @@
|
||||
|
||||
## 最新动态
|
||||
|
||||
* *<mark>[new]</mark>* 🔥🔥🔥 **[2026-10]**: 📦 **正式发布 [MemHub v1.0.4](https://github.com/Tencent-Hunyuan/Hy-Memory/releases/tag/v1.0.4)** 与 **[memhub-cli 1.0.5](https://www.npmjs.com/package/memhub-cli/v/1.0.5)**，提供已签名的 macOS 桌面应用及经过验证的 macOS/Linux Runtime！
|
||||
* *<mark>[new]</mark>* 🔥🔥🔥 **[2026-10]**: 🚀 **正式发布** **Hy Memory 2.0 (`hy-memory==2.0.4`)**（已上线 [PyPI](https://pypi.org/project/hy-memory/2.0.4/)），并开源 **Hy-Memory** monorepo 与 **[MemHub](memhub/README.md)**！
|
||||
* *<mark>[new]</mark>* 🔥🔥🔥 **[2026-10]**: 🚀 **正式发布** **Hy Memory 2.0 (`hy-memory==2.0.3`)**（已上线 [PyPI](https://pypi.org/project/hy-memory/2.0.3/)），并开源 **Hy-Memory** monorepo 与 **[MemHub](memhub/README.md)**！
|
||||
* *<mark>[new]</mark>* 🔥🔥🔥 **[2026-10]**: 🚀 **模型开源** 在 Hugging Face 发布 **[Hy-Memory-30B-A3B](https://huggingface.co/tencent/Hy-Memory-30B-A3B)** 长期记忆写入模型及[技术报告](https://arxiv.org/abs/2610.22196)！
|
||||
* *<mark>[new]</mark>* 🔥🔥 **[2026-09]**: 📊 **基准与方法发布** 推出长周期与交错式编程记忆评测基准 **[CMB: A Coding Memory Benchmark for Long-Horizon and Interleaved Coding Agents](docs/papers/CMB_A_Coding_Memory_Benchmark_for_Long_Horizon_and_Interleaved_Coding_Agents.pdf)**（已投稿 **ICLR 2027**）。
|
||||
* *<mark>[new]</mark>* 🔥🔥 **[2026-08]**: 🎉 **论文录用** 双系统认知记忆架构论文 **[Memory Beyond Recall: A Dual-Process Cognitive Memory System for Self-Evolving LLM Agents](https://arxiv.org/abs/2606.09483)** 被 **EMNLP 2026** 接收！
|
||||
|
||||
@@ -282,24 +282,11 @@ class PollingLiveSyncSupervisor:
|
||||
and job.status
|
||||
in {ImportStatus.PENDING, ImportStatus.RUNNING, ImportStatus.INTERRUPTED}
|
||||
]
|
||||
bounded_history_incomplete = any(
|
||||
job.source_id == source_id
|
||||
and job.operation == "history"
|
||||
and job.history_after is not None
|
||||
and job.status is not ImportStatus.COMPLETED
|
||||
for job in source_jobs
|
||||
)
|
||||
# Establish the realtime EOF independently even while history owns
|
||||
# this source. Otherwise the P1 job starts from the P2 checkpoint
|
||||
# (or from zero) and becomes a second full-history scan.
|
||||
adapter = self.import_supervisor.adapters[source_id]
|
||||
live_cursors = await self._live_cursors(source_id, adapter)
|
||||
# A bounded onboarding history is the authority for everything up
|
||||
# to its EOF. An adapter without a native live baseline has no safe
|
||||
# realtime cursor until that history finishes; starting a sync from
|
||||
# zero here would bypass `history_after` and import the old corpus.
|
||||
if bounded_history_incomplete and not live_cursors:
|
||||
return None
|
||||
await self._live_cursors(source_id, adapter)
|
||||
# Only one scan of a source may be in flight: they share the
|
||||
# cursor, and two readers means every file read twice. With a
|
||||
# catch-up still holding the source there is no free moment to ask
|
||||
|
||||
@@ -94,67 +94,6 @@ class SettledFixtureAdapter(IncrementalFixtureAdapter):
|
||||
}
|
||||
|
||||
|
||||
class BoundedOnboardingAdapter:
|
||||
"""No native baseline: bounded history must establish the live cursor."""
|
||||
|
||||
descriptor = IncrementalFixtureAdapter.descriptor
|
||||
|
||||
def __init__(self) -> None:
|
||||
self.include_new = False
|
||||
|
||||
async def detect(self) -> bool:
|
||||
return True
|
||||
|
||||
async def scan(self, options: ScanOptions):
|
||||
current = options.cursors.get("e" * 64)
|
||||
checkpoint = current.checkpoint if current is not None else None
|
||||
if checkpoint not in {"byte:10", "byte:20"}:
|
||||
yield ScannedEvidence(
|
||||
evidence=EvidenceInput(
|
||||
source_id="fixture",
|
||||
conversation_id="old-conversation",
|
||||
message_id="old-message",
|
||||
role="user",
|
||||
written_by=WrittenBy.PERSON,
|
||||
created_at=datetime(2020, 1, 1, tzinfo=UTC),
|
||||
verbatim="old history",
|
||||
origin_meta={EvidenceOrigin.FILE: OriginMetadata()},
|
||||
),
|
||||
cursor=SourceCursor(
|
||||
file_key="e" * 64,
|
||||
file_identity="bounded",
|
||||
checkpoint="byte:10",
|
||||
checkpoint_anchor="f" * 64,
|
||||
observed_size=20,
|
||||
observed_modified_ns=1,
|
||||
),
|
||||
)
|
||||
checkpoint = "byte:10"
|
||||
if self.include_new and checkpoint != "byte:20":
|
||||
yield ScannedEvidence(
|
||||
evidence=EvidenceInput(
|
||||
source_id="fixture",
|
||||
conversation_id="new-conversation",
|
||||
message_id="new-message",
|
||||
role="user",
|
||||
written_by=WrittenBy.PERSON,
|
||||
created_at=datetime(2026, 10, 18, tzinfo=UTC),
|
||||
verbatim="new append",
|
||||
origin_meta={EvidenceOrigin.FILE: OriginMetadata()},
|
||||
),
|
||||
cursor=SourceCursor(
|
||||
file_key="e" * 64,
|
||||
file_identity="bounded",
|
||||
checkpoint="byte:20",
|
||||
checkpoint_anchor="1" * 64,
|
||||
observed_size=20,
|
||||
observed_modified_ns=2,
|
||||
read_to_end=True,
|
||||
),
|
||||
)
|
||||
yield ScanProgressEvent(phase=ScanPhase.DONE)
|
||||
|
||||
|
||||
class HoldingHistoryAdapter:
|
||||
"""First scan blocks until cancelled; later scans yield one new record."""
|
||||
|
||||
@@ -389,56 +328,6 @@ def test_live_sync_does_not_resume_a_history_import_the_user_paused(tmp_path) ->
|
||||
asyncio.run(scenario())
|
||||
|
||||
|
||||
def test_bounded_onboarding_history_establishes_cursor_before_first_sync(tmp_path) -> None:
|
||||
async def scenario() -> None:
|
||||
database = tmp_path / "one-memory.sqlite3"
|
||||
evidence = EvidenceStore(database)
|
||||
jobs = ImportJobStore(database)
|
||||
adapter = BoundedOnboardingAdapter()
|
||||
imports = ImportSupervisor(
|
||||
adapters={"fixture": adapter},
|
||||
evidence_store=evidence,
|
||||
job_store=jobs,
|
||||
)
|
||||
live_sync = PollingLiveSyncSupervisor(
|
||||
source_ids=("fixture",),
|
||||
import_supervisor=imports,
|
||||
job_store=jobs,
|
||||
)
|
||||
history = imports.create_job("fixture", operation="history")
|
||||
with sqlite3.connect(database) as connection, connection:
|
||||
connection.execute(
|
||||
"UPDATE import_jobs SET history_after=? WHERE job_id=?",
|
||||
(datetime(2026, 10, 15, tzinfo=UTC).isoformat(), history.job_id),
|
||||
)
|
||||
|
||||
# With no native baseline, sync must wait instead of scanning from zero
|
||||
# and bypassing the onboarding history window.
|
||||
assert await live_sync.trigger("fixture") is None
|
||||
assert not [job for job in jobs.list_jobs() if job.operation == "sync"]
|
||||
|
||||
imports.enqueue(history.job_id)
|
||||
completed = await imports.wait(history.job_id)
|
||||
assert completed.status is ImportStatus.COMPLETED
|
||||
assert completed.stored == 0
|
||||
assert completed.skipped == 1
|
||||
assert evidence.count() == 0
|
||||
|
||||
# Once bounded history has advanced the cursor to EOF, normal realtime
|
||||
# appends are admitted without retaining the three-day cutoff forever.
|
||||
adapter.include_new = True
|
||||
synced = await live_sync.trigger("fixture")
|
||||
assert synced is not None
|
||||
assert synced.status is ImportStatus.COMPLETED
|
||||
assert synced.stored == 1
|
||||
records = evidence.list_extractable()
|
||||
assert [record.verbatim for record in records] == ["new append"]
|
||||
await live_sync.shutdown()
|
||||
await imports.shutdown()
|
||||
|
||||
asyncio.run(scenario())
|
||||
|
||||
|
||||
def test_a_sync_left_running_after_its_worker_died_is_started_again(tmp_path) -> None:
|
||||
"""A running row with no live worker used to be returned as 'already syncing'.
|
||||
|
||||
|
||||
@@ -8,7 +8,6 @@ import {
|
||||
mkdir,
|
||||
readdir,
|
||||
readFile,
|
||||
readlink,
|
||||
realpath,
|
||||
rm,
|
||||
stat,
|
||||
@@ -321,12 +320,6 @@ async function distributionBytes(source) {
|
||||
|
||||
async function sha256File(file) {
|
||||
const digest = createHash("sha256");
|
||||
const info = await lstat(file);
|
||||
if (info.isSymbolicLink()) {
|
||||
digest.update("symlink\0");
|
||||
digest.update(await readlink(file));
|
||||
return digest.digest("hex");
|
||||
}
|
||||
for await (const chunk of createReadStream(file)) digest.update(chunk);
|
||||
return digest.digest("hex");
|
||||
}
|
||||
|
||||
@@ -6,7 +6,6 @@ import {
|
||||
readdir,
|
||||
readFile,
|
||||
rm,
|
||||
symlink,
|
||||
writeFile,
|
||||
} from "node:fs/promises";
|
||||
import os from "node:os";
|
||||
@@ -122,35 +121,6 @@ test("builds versioned Runtime archives, checksums and a downloader-compatible m
|
||||
}
|
||||
});
|
||||
|
||||
test("verifies Runtime symlinks with the same identity rule as the installer", async (t) => {
|
||||
const root = await mkdtemp(path.join(os.tmpdir(), "memhub-release-assets-"));
|
||||
t.after(() => rm(root, { recursive: true, force: true }));
|
||||
const source = await distribution(root, "linux", "x64");
|
||||
const link = "memhub";
|
||||
await symlink(link, path.join(source, "bin", "node"));
|
||||
const manifestPath = path.join(source, "manifest.json");
|
||||
const manifest = JSON.parse(await readFile(manifestPath, "utf8"));
|
||||
manifest.files["bin/node"] = sha256(`symlink\0${link}`);
|
||||
await writeFile(manifestPath, `${JSON.stringify(manifest, null, 2)}\n`);
|
||||
|
||||
const release = await buildReleaseAssets({
|
||||
output: path.join(root, "release"),
|
||||
version: "0.1.0-internal.1",
|
||||
channel: "prerelease",
|
||||
assetBaseUrl: "https://git.example.test/release/downloads/",
|
||||
distributions: [source],
|
||||
});
|
||||
|
||||
assert.ok(
|
||||
release.artifacts.some(
|
||||
(artifact) =>
|
||||
artifact.kind === "runtime" &&
|
||||
artifact.platform === "linux" &&
|
||||
artifact.arch === "x64",
|
||||
),
|
||||
);
|
||||
});
|
||||
|
||||
test("refuses version, build and duplicate target drift", async (t) => {
|
||||
const root = await mkdtemp(path.join(os.tmpdir(), "memhub-release-assets-"));
|
||||
t.after(() => rm(root, { recursive: true, force: true }));
|
||||
|
||||
Reference in new issue
Block a user