Rinne414/lora-training-skill

`--apply` 之前 `fix_dataset.py` 会先问 trainer（`GET /api/datasets/in-use`）这个文件夹是不是正被排队或运行中的训练使用：是 → 退出码 3 并打印 STOP，什么都不改；先问用户，同意后同一条命令加 `--allow-in-use`。dry-run 不问；trainer 没开或太旧只打一行提示、照常继续（`--trainer-url` 可改地址，默认 `http://127.0.0.1:28000`）。

`--apply` 之前 `fix_dataset.py` 会先问 trainer（`GET /api/datasets/in-use`）这个文件夹是不是正被排队或运行中的训练使用：是 → 退出码 3 并打印 STOP，什么都不改；先问用户，同意后同一条命令加 `--allow-in-use`。dry-run 不问；trainer 没开或太旧只打一行提示、照常继续（`--trainer-url` 可改地址，默认 `http://127.0.0.1:28000`）。

`--apply` 之前 `fix_dataset.py` 会先问 trainer（`GET /api/datasets/in-use`）这个文件夹是不是正被排队或运行中的训练使用：是 → 退出码 3 并打印 STOP，什么都不改；先问用户，同意后同一条命令加 `--allow-in-use`。dry-run 不问；trainer 没开或太旧只打一行提示、照常继续（`--trainer-url` 可改地址，默认 `http://127.0.0.1:28000`）。

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

p.add_argument(             "--trainer-url",             default=os.environ.get("SD_TRAINER_URL", "http://127.0.0.1:28000"),

p.add_argument(             "--trainer-url",             default=os.environ.get("SD_TRAINER_URL", "http://127.0.0.1:28000"),

"--trainer-url",             default=os.environ.get("SD_TRAINER_URL", "http://127.0.0.1:28000"),             help="SD-Trainer base URL, asked before --apply whether the dataset is in use",

"--trainer-url",             default=os.environ.get("SD_TRAINER_URL", "http://127.0.0.1:28000"),             help="SD-Trainer base URL, asked before --apply whether the dataset is in use",

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

Executable file

Executable file

Executable file

Executable file

Executable file

handler = type("H", (Handler,), {"status": status, "body": body})         self.server = HTTPServer(("127.0.0.1", 0), handler)         self.url = f"http://127.0.0.1:{self.server.server_port}"

self.url = f"http://127.0.0.1:{self.server.server_port}"

def test_dry_run_never_asks_the_trainer(self) -> None:         with mock.patch.object(X, "guard_apply", side_effect=AssertionError("asked")):             code, _ = self.run_fix("http://127.0.0.1:9")

with mock.patch.object(X, "guard_apply", side_effect=AssertionError("asked")):             code, _ = self.run_fix("http://127.0.0.1:9")         self.assertEqual(code, 0)

code, _ = self.run_fix("http://127.0.0.1:9")

self.assertEqual(self.run_fix(trainer.url, "--apply")[0], 0)         self.caption.write_text("1girl, 2girls", encoding="utf-8")         code, err = self.run_fix("http://127.0.0.1:9", "--apply")

self.caption.write_text("1girl, 2girls", encoding="utf-8")         code, err = self.run_fix("http://127.0.0.1:9", "--apply")         self.assertEqual(code, 0)

code, err = self.run_fix("http://127.0.0.1:9", "--apply")

def test_missing_guard_module_is_a_note_not_an_error(self) -> None:         with mock.patch.object(X, "load_in_use_guard", return_value=None):             self.assertEqual(X.guard_apply(self.root, "http://127.0.0.1:9", False), 0)

self.assertEqual(X.guard_apply(self.root, "http://127.0.0.1:9", False), 0)

Executable file

NO_TRAINER = ["--trainer-url", "http://127.0.0.1:9"]  # never ask a real trainer from a test

Executable file

NO_TRAINER = ["--trainer-url", "http://127.0.0.1:9"]  # never ask a real trainer from a test

|---|---|---| | DanbooruDownload | 按 tag 下载图 | `C:\tools\DanbooruDownload`(env `DANBOORU_DL_DIR`) | | sd-image-sorter | WD14 打标 FastAPI | [Rinne414/sd-image-sorter](https://github.com/Rinne414/sd-image-sorter),`:8487`,兼容版本见 `collect-and-tag

| DanbooruDownload | 按 tag 下载图 | `C:\tools\DanbooruDownload`(env `DANBOORU_DL_DIR`) | | sd-image-sorter | WD14 打标 FastAPI | [Rinne414/sd-image-sorter](https://github.com/Rinne414/sd-image-sorter),`:8487`,兼容版本见 `collect-and-tag.md` | | SD-Tr

| sd-image-sorter | WD14 打标 FastAPI | [Rinne414/sd-image-sorter](https://github.com/Rinne414/sd-image-sorter),`:8487`,兼容版本见 `collect-and-tag.md` |

| SD-Trainer | 训练后端 mikazuki API | `http://127.0.0.1:28000`,`run_gui.bat` 启动 |

| ComfyUI | 验证出图 | `http://127.0.0.1:8188`(env `COMFY_URL`) |

Executable file

"""Phase 1 — COLLECT. Download a character/concept image set from Danbooru via the DanbooruDownload CLI (https://github.com/storyAura/DanbooruDownload).

Executable file

the DanbooruDownload CLI (https://github.com/storyAura/DanbooruDownload).

[Credential-related source omitted]

Executable file

def source_url(image: Path) -> str | None:     return f"https://danbooru.donmai.us/posts/{image.stem}" if image.stem.isdigit() else None

return f"https://danbooru.donmai.us/posts/{image.stem}" if image.stem.isdigit() else None

Executable file

Executable file

[Credential-related source omitted]

[Credential-related source omitted]

url = f"{base_url.rstrip('/')}/api/datasets/in-use?{query}"     try:         with urllib.request.urlopen(url, timeout=timeout) as response:  # noqa: S310 - local trusted service

try:         with urllib.request.urlopen(url, timeout=timeout) as response:  # noqa: S310 - local trusted service             payload = json.loads(response.read().decode("utf-8"))

with urllib.request.urlopen(url, timeout=timeout) as response:  # noqa: S310 - local trusted service

Executable file

Executable file

Executable file

Executable file

Flow (sd-image-sorter, http://127.0.0.1:8487, env SORTER_URL):

Flow (sd-image-sorter, http://127.0.0.1:8487, env SORTER_URL):

Flow (sd-image-sorter, http://127.0.0.1:8487, env SORTER_URL):

the user has agreed. Environment overrides:   SORTER_URL   base URL of sd-image-sorter (default http://127.0.0.1:8487)

the user has agreed. Environment overrides:   SORTER_URL   base URL of sd-image-sorter (default http://127.0.0.1:8487)

the user has agreed. Environment overrides:   SORTER_URL   base URL of sd-image-sorter (default http://127.0.0.1:8487)

Environment overrides:   SORTER_URL   base URL of sd-image-sorter (default http://127.0.0.1:8487) """

Environment overrides:   SORTER_URL   base URL of sd-image-sorter (default http://127.0.0.1:8487) """

Environment overrides:   SORTER_URL   base URL of sd-image-sorter (default http://127.0.0.1:8487) """

SORTER_URL   base URL of sd-image-sorter (default http://127.0.0.1:8487)

SORTER_URL   base URL of sd-image-sorter (default http://127.0.0.1:8487)

SORTER_URL   base URL of sd-image-sorter (default http://127.0.0.1:8487)

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

url = SORTER + path     data = json.dumps(body).encode() if body is not None else None     req = urllib.request.Request(

url = SORTER + path     data = json.dumps(body).encode() if body is not None else None     req = urllib.request.Request(

url = SORTER + path     data = json.dumps(body).encode() if body is not None else None     req = urllib.request.Request(

data = json.dumps(body).encode() if body is not None else None     req = urllib.request.Request(         url,

data = json.dumps(body).encode() if body is not None else None     req = urllib.request.Request(         url,

data = json.dumps(body).encode() if body is not None else None     req = urllib.request.Request(         url,

req = urllib.request.Request(

req = urllib.request.Request(

req = urllib.request.Request(

for attempt in range(1, REQUEST_ATTEMPTS + 1):         try:             with urllib.request.urlopen(req, timeout=timeout) as r:  # noqa: S310 — local trusted service

for attempt in range(1, REQUEST_ATTEMPTS + 1):         try:             with urllib.request.urlopen(req, timeout=timeout) as r:  # noqa: S310 — local trusted service

for attempt in range(1, REQUEST_ATTEMPTS + 1):         try:             with urllib.request.urlopen(req, timeout=timeout) as r:  # noqa: S310 — local trusted service

try:             with urllib.request.urlopen(req, timeout=timeout) as r:  # noqa: S310 — local trusted service                 response = json.loads(r.read().decode())

try:             with urllib.request.urlopen(req, timeout=timeout) as r:  # noqa: S310 — local trusted service                 response = json.loads(r.read().decode())

try:             with urllib.request.urlopen(req, timeout=timeout) as r:  # noqa: S310 — local trusted service                 response = json.loads(r.read().decode())

with urllib.request.urlopen(req, timeout=timeout) as r:  # noqa: S310 — local trusted service

with urllib.request.urlopen(req, timeout=timeout) as r:  # noqa: S310 — local trusted service

with urllib.request.urlopen(req, timeout=timeout) as r:  # noqa: S310 — local trusted service

Executable file

--trigger mych4r --target character --subject-tag 1girl Environment overrides:   COMFY_URL   base URL of ComfyUI (default http://127.0.0.1:8188)

Environment overrides:   COMFY_URL   base URL of ComfyUI (default http://127.0.0.1:8188) """

COMFY_URL   base URL of ComfyUI (default http://127.0.0.1:8188)

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

def read_response(request: str | urllib.request.Request, timeout: int) -> bytes:

request_url = request.full_url if isinstance(request, urllib.request.Request) else request

for attempt in range(1, REQUEST_ATTEMPTS + 1):         try:             with urllib.request.urlopen(request, timeout=timeout) as response:  # noqa: S310

try:             with urllib.request.urlopen(request, timeout=timeout) as response:  # noqa: S310                 return response.read()

with urllib.request.urlopen(request, timeout=timeout) as response:  # noqa: S310

def post(wf: dict) -> str:     req = urllib.request.Request(

req = urllib.request.Request(

Executable file

self.handler = handler         self.server = HTTPServer(("127.0.0.1", 0), handler)         self.url = f"http://127.0.0.1:{self.server.server_port}"

self.server = HTTPServer(("127.0.0.1", 0), handler)         self.url = f"http://127.0.0.1:{self.server.server_port}"         self.thread = threading.Thread(target=self.server.serve_forever, daemon=True)

self.url = f"http://127.0.0.1:{self.server.server_port}"

self.assertEqual(             guard.check_in_use("D:/x", "http://127.0.0.1:9", timeout=1)["state"], "unknown"

guard.check_in_use("D:/x", "http://127.0.0.1:9", timeout=1)["state"], "unknown"

def test_unreachable_trainer_does_not_block_a_build(self):         self.assertEqual(self.run_main("http://127.0.0.1:9"), 0)

self.assertEqual(self.run_main("http://127.0.0.1:9"), 0)

with TrainerStub(404, {"detail": "Not Found"}) as stub:             self.assertEqual(self.run_main(stub.url), -1)         self.assertEqual(self.run_main("http://127.0.0.1:9"), -1)

self.assertEqual(self.run_main("http://127.0.0.1:9"), -1)

Executable file

self.assertEqual(             curate.source_url(Path("123456.png")),             "https://danbooru.donmai.us/posts/123456",

curate.source_url(Path("123456.png")),             "https://danbooru.donmai.us/posts/123456",         )

"https://danbooru.donmai.us/posts/123456",

底层 = `lora-scripts-next`（SD-Trainer）的 `mikazuki` FastAPI（`http://127.0.0.1:28000`，路由前缀 `/api`）。完整契约见 `../references/trainer-api.md`。

底层 = `lora-scripts-next`（SD-Trainer）的 `mikazuki` FastAPI（`http://127.0.0.1:28000`，路由前缀 `/api`）。完整契约见 `../references/trainer-api.md`。

#!/usr/bin/env python3

DEFAULT_BASE_URL = "http://127.0.0.1:28000"

def _get_json(url: str) -> tuple[int, Any]:     try:         with urllib.request.urlopen(url, timeout=REQUEST_TIMEOUT_SECONDS) as response:  # noqa: S310

try:         with urllib.request.urlopen(url, timeout=REQUEST_TIMEOUT_SECONDS) as response:  # noqa: S310             status, body = response.status, response.read()

with urllib.request.urlopen(url, timeout=REQUEST_TIMEOUT_SECONDS) as response:  # noqa: S310

#!/usr/bin/env python3

#!/usr/bin/env python3

DEFAULT_BASE_URL = "http://127.0.0.1:28000"

try:         with urllib.request.urlopen(url, timeout=timeout) as response:

with urllib.request.urlopen(url, timeout=timeout) as response:

#!/usr/bin/env python3

DEFAULT_BASE_URL = "http://127.0.0.1:28000"

url = f"{base_url.rstrip('/')}{path}"     data = None if body is None else json.dumps(body).encode("utf-8")     request = urllib.request.Request(

data = None if body is None else json.dumps(body).encode("utf-8")     request = urllib.request.Request(         url,

request = urllib.request.Request(

)     try:         with urllib.request.urlopen(request, timeout=REQUEST_TIMEOUT_SECONDS) as response:  # noqa: S310

try:         with urllib.request.urlopen(request, timeout=REQUEST_TIMEOUT_SECONDS) as response:  # noqa: S310             status, raw = response.status, response.read()

with urllib.request.urlopen(request, timeout=REQUEST_TIMEOUT_SECONDS) as response:  # noqa: S310

#!/usr/bin/env python3

DEFAULT_BASE_URL = "http://127.0.0.1:28000"

try:         with urllib.request.urlopen(  # noqa: S310 - local trusted service

with urllib.request.urlopen(  # noqa: S310 - local trusted service

Executable file

"UserWarning: pkg_resources is deprecated as an API.",     'INFO:     127.0.0.1:50190 - "GET /api/train/log/tail/abc?limit=12 HTTP/1.1" 200 OK',     "INFO: Uvicorn running on http://127.0.0.1:28000",

'INFO:     127.0.0.1:50190 - "GET /api/train/log/tail/abc?limit=12 HTTP/1.1" 200 OK',     "INFO: Uvicorn running on http://127.0.0.1:28000",     'loss_type = "l2"',

"INFO: Uvicorn running on http://127.0.0.1:28000",

[Credential-related source omitted]

self.addCleanup(self.server.server_close)         self.addCleanup(self.server.shutdown)         self.url = f"http://127.0.0.1:{self.server.server_port}"

self.addCleanup(self.server.shutdown)         self.url = f"http://127.0.0.1:{self.server.server_port}"         self._tmp = tempfile.TemporaryDirectory()

self.url = f"http://127.0.0.1:{self.server.server_port}"

def test_unreachable_trainer_is_reported(self) -> None:         result = fc.poll_trainer("http://127.0.0.1:1", "t1", self.state, now=0.0)

result = fc.poll_trainer("http://127.0.0.1:1", "t1", self.state, now=0.0)

Executable file

Executable file

@property     def url(self) -> str:         return f"http://127.0.0.1:{self.server.server_port}"

return f"http://127.0.0.1:{self.server.server_port}"

self.assertEqual(result["source"], "trainer_api")         self.assertEqual([i["name"] for i in result["previews"]], ["run_e000001_00_a.png"])         self.assertTrue(result["previews"][0]["url"].startswith("http://127.0.0.1:"))

self.assertEqual([i["name"] for i in result["previews"]], ["run_e000001_00_a.png"])         self.assertTrue(result["previews"][0]["url"].startswith("http://127.0.0.1:"))         summary = result["loss_summary"]

self.assertTrue(result["previews"][0]["url"].startswith("http://127.0.0.1:"))

Executable file

self.addCleanup(self.server.server_close)         self.addCleanup(self.server.shutdown)         self.url = f"http://127.0.0.1:{self.server.server_port}"

self.addCleanup(self.server.shutdown)         self.url = f"http://127.0.0.1:{self.server.server_port}"         self._tmp = tempfile.TemporaryDirectory()

self.url = f"http://127.0.0.1:{self.server.server_port}"

def test_unreachable_trainer_is_a_note_not_a_crash(self) -> None:         result = ts.preflight("http://127.0.0.1:1", "anima-lora", {})

result = ts.preflight("http://127.0.0.1:1", "anima-lora", {})

Fake.run_response = {             "status": "success",             "data": {"task_id": "t-1", "train_log_stream_url": "http://x/stream"},

"status": "success",             "data": {"task_id": "t-1", "train_log_stream_url": "http://x/stream"},         }

"data": {"task_id": "t-1", "train_log_stream_url": "http://x/stream"},

Executable file

self.addCleanup(server.server_close)         self.addCleanup(server.shutdown)         url = f"http://127.0.0.1:{server.server_port}"

self.addCleanup(server.shutdown)         url = f"http://127.0.0.1:{server.server_port}"         self.assertEqual(ws.task_config_name(url, "t1"), "20261027-1.toml")

url = f"http://127.0.0.1:{server.server_port}"

self.assertEqual(ws.task_config_name(url, "t1"), "20261027-1.toml")         self.assertIsNone(ws.task_config_name(url, "other"))         self.assertIsNone(ws.task_config_name("http://127.0.0.1:1", "t1"))

self.assertIsNone(ws.task_config_name("http://127.0.0.1:1", "t1"))

**Anima official model card** ([circlestone-labs/Anima](https://huggingface.co/circlestone-labs/Anima)):

**Anima official model card** ([circlestone-labs/Anima](https://huggingface.co/circlestone-labs/Anima)):

**Anima official model card** ([circlestone-labs/Anima](https://huggingface.co/circlestone-labs/Anima)):

Tool: **DanbooruDownload** (`https://github.com/storyAura/DanbooruDownload`), a CLI

Tool: **[Rinne414/sd-image-sorter](https://github.com/Rinne414/sd-image-sorter)** — a

revision is `c449e3f3ab8057353955d8128ad46a6763daa5e9` or newer; the driver also checks required OpenAPI paths before changing captions. Run `run.bat` → serves `http://127.0.0.1:8487` (env `SORTER_URL`). Models

required OpenAPI paths before changing captions. Run `run.bat` → serves `http://127.0.0.1:8487` (env `SORTER_URL`). Models `wd-eva02-large-tagger-v3` / `wd-swinv2-tagger-v3` / `camie-tagger-v2` /

`http://127.0.0.1:8487` (env `SORTER_URL`). Models

> The trainer must be running. Launch it with `run_gui.bat` (portable) or > `python gui.py`. The backend then serves on **`http://127.0.0.1:28000`** and

> The trainer must be running. Launch it with `run_gui.bat` (portable) or > `python gui.py`. The backend then serves on **`http://127.0.0.1:28000`** and

> `python gui.py`. The backend then serves on **`http://127.0.0.1:28000`** and

> `python gui.py`. The backend then serves on **`http://127.0.0.1:28000`** and

"train_log_path": "/train-log",     "train_log_stream": "/api/train/log/stream/<task_id>",     "train_log_url": "http://127.0.0.1:28000/train-log?task_id=<task_id>",

"train_log_path": "/train-log",     "train_log_stream": "/api/train/log/stream/<task_id>",     "train_log_url": "http://127.0.0.1:28000/train-log?task_id=<task_id>",

"train_log_stream": "/api/train/log/stream/<task_id>",     "train_log_url": "http://127.0.0.1:28000/train-log?task_id=<task_id>",     "train_log_stream_url": "http://127.0.0.1:28000/api/train/log/stream/<task_id>"

"train_log_stream": "/api/train/log/stream/<task_id>",     "train_log_url": "http://127.0.0.1:28000/train-log?task_id=<task_id>",     "train_log_stream_url": "http://127.0.0.1:28000/api/train/log/stream/<task_id>"

"train_log_url": "http://127.0.0.1:28000/train-log?task_id=<task_id>",

"train_log_url": "http://127.0.0.1:28000/train-log?task_id=<task_id>",

"train_log_stream_url": "http://127.0.0.1:28000/api/train/log/stream/<task_id>"

"train_log_stream_url": "http://127.0.0.1:28000/api/train/log/stream/<task_id>"

$body = Get-Content config.json -Raw $r = Invoke-RestMethod -Uri http://127.0.0.1:28000/api/run -Method Post `

$body = Get-Content config.json -Raw $r = Invoke-RestMethod -Uri http://127.0.0.1:28000/api/run -Method Post `

$r = Invoke-RestMethod -Uri http://127.0.0.1:28000/api/run -Method Post `

$r = Invoke-RestMethod -Uri http://127.0.0.1:28000/api/run -Method Post `

$body = @{ path = "D:/data/myproject/5_zkz"; additional_tags = "zkz"; threshold = 0.35 } | ConvertTo-Json Invoke-RestMethod -Uri http://127.0.0.1:28000/api/interrogate -Method Post `

$body = @{ path = "D:/data/myproject/5_zkz"; additional_tags = "zkz"; threshold = 0.35 } | ConvertTo-Json Invoke-RestMethod -Uri http://127.0.0.1:28000/api/interrogate -Method Post `

Invoke-RestMethod -Uri http://127.0.0.1:28000/api/interrogate -Method Post `

Invoke-RestMethod -Uri http://127.0.0.1:28000/api/interrogate -Method Post `

Before publishing, prove the character is consistent. Driver: `lora-pipeline/scripts/validate.py` → drives ComfyUI's API (`http://127.0.0.1:8188`, env `COMFY_URL`).

(`http://127.0.0.1:8188`, env `COMFY_URL`).