Skip to content

emrg: task CRUD + template CRUD + hot reload (rant 2026-08-12T18:23:15 P2) #710

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
argszero merged 1 commit into from
Aug 12, 2026
Merged

emrg: task CRUD + template CRUD + hot reload (rant 2026-08-12T18:23:15 P2) #710

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion Agent.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -112,7 +112,7 @@ Community needs voiced in HN agent-UI discussions map directly to EMRG's design:
pkill -f "emrg.server"; rm -f ~/.emrg/emrgd.port; python -m emrg
```

Python: `uv run pytest tests/ -v` (736) — import check: `uv run python -c "from emrg.client.app import run_client"`
Python: `uv run pytest tests/ -v` (744) — import check: `uv run python -c "from emrg.client.app import run_client"`
GUI: `cd emrg/gui && npm test` (225: 43 daemon_client + 19 conn-manager + 22 app-commands + 104 renderer smoke + 15 i18n + 7 integration + 3 commands + 5 build-config + 7 gui-state) — syntax: `node --check main.js preload.js daemon_client.js renderer/js/*.js`
CI: `uv run pytest` + GUI tests + **actionlint workflow lint** (`rhysd/actionlint@v1.7.12` gate, #444 — workflow 解析错误在 PR CI 即失败，如 `if:` secrets 上下文)
Re-trigger: `scripts/re-trigger-ci.sh [branch]` (workflow_dispatch, #527 — 替代空 commit 重触发：Actions outage 会整段丢弃 push 事件，dispatch 走 API 路径不受影响)
Expand Down
77 changes: 77 additions & 0 deletions emrg/server/daemon.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1217,6 +1217,83 @@ async def _process_message(
"error": "scheduler not running",
})

elif msg_type == "task_create":
# rant 2026-08-12T18:23:15 P2 — task CRUD with hot reload
if not self._scheduler:
await self._send(ws, {"type": "task_result", "error": "scheduler not running"})
return
ok, res = self._scheduler.task_create(
name=msg.get("name", "").strip(),
task_type=msg.get("type", "").strip(),
project=msg.get("project", "").strip(),
interval=msg.get("interval"),
enabled=msg.get("enabled", True),
repo=msg.get("repo"),
description=msg.get("description"),
)
if not ok:
await self._send(ws, {"type": "task_result", "error": res})
return
summary = await self._scheduler.apply_tasks(self._scheduler._load_tasks())
await self._send(ws, {"type": "task_result", "ok": True, "task": res, "summary": summary})

elif msg_type == "task_update":
if not self._scheduler:
await self._send(ws, {"type": "task_result", "error": "scheduler not running"})
return
fields = {k: msg[k] for k in ("type", "project", "interval", "enabled", "repo", "description") if k in msg}
ok, res = self._scheduler.task_update(msg.get("name", "").strip(), **fields)
if not ok:
await self._send(ws, {"type": "task_result", "error": res})
return
summary = await self._scheduler.apply_tasks(self._scheduler._load_tasks())
await self._send(ws, {"type": "task_result", "ok": True, "task": res, "summary": summary})

elif msg_type == "task_delete":
if not self._scheduler:
await self._send(ws, {"type": "task_result", "error": "scheduler not running"})
return
ok, err = self._scheduler.task_delete(msg.get("name", "").strip())
if not ok:
await self._send(ws, {"type": "task_result", "error": err})
return
summary = await self._scheduler.apply_tasks(self._scheduler._load_tasks())
await self._send(ws, {"type": "task_result", "ok": True, "summary": summary})

elif msg_type == "task_template_list":
if not self._scheduler:
await self._send(ws, {"type": "templates_list", "templates": []})
return
await self._send(ws, {
"type": "templates_list",
"templates": self._scheduler.list_templates(),
})

elif msg_type == "task_template_create":
if not self._scheduler:
await self._send(ws, {"type": "template_result", "error": "scheduler not running"})
return
ok, err = self._scheduler.template_create(
msg.get("name", "").strip(), msg.get("prompt", "")
)
await self._send(ws, {"type": "template_result", "ok": ok, **({"error": err} if not ok else {})})

elif msg_type == "task_template_update":
if not self._scheduler:
await self._send(ws, {"type": "template_result", "error": "scheduler not running"})
return
ok, err = self._scheduler.template_update(
msg.get("name", "").strip(), msg.get("prompt", "")
)
await self._send(ws, {"type": "template_result", "ok": ok, **({"error": err} if not ok else {})})

elif msg_type == "task_template_delete":
if not self._scheduler:
await self._send(ws, {"type": "template_result", "error": "scheduler not running"})
return
ok, err = self._scheduler.template_delete(msg.get("name", "").strip())
await self._send(ws, {"type": "template_result", "ok": ok, **({"error": err} if not ok else {})})

elif msg_type == "compact":
cwd = msg.get("cwd", "")
session_id = msg.get("session_id", "")
Expand Down
Loading
Loading