diff --git a/apps/dag_engine/README.md b/apps/dag_engine/README.md index ef73b036..53132d50 100644 --- a/apps/dag_engine/README.md +++ b/apps/dag_engine/README.md @@ -16,7 +16,7 @@ Por defecto el systemd unit apunta a `apps/dag_engine/dags/`. Para usar otro dir ```ini ExecStart=/home/lucas/fn_registry/apps/dag_engine/dag_engine server \ - --port 8090 \ + --port 4200 \ --dags-dir /home/lucas/fn_registry/apps/dag_engine/dags \ --db /home/lucas/fn_registry/apps/dag_engine/dag_engine.db \ --scheduler @@ -52,12 +52,12 @@ systemctl --user restart dag_engine.service Busca la linea `[scheduler] ticker started for ()` en los logs. 5. **Verificar en frontend**: - C++ ImGui: panel `DAGs` muestra el nuevo DAG. Pulsa `Refresh` si no aparece. - - Web: `http://localhost:8090`. + - Web: `http://localhost:4200`. ### Disparo manual desde curl o frontend ```bash -curl -X POST http://127.0.0.1:8090/api/dags//run +curl -X POST http://127.0.0.1:4200/api/dags//run ``` Devuelve `{"dag":"","run_id":"...","status":"accepted"}` y dispara el WS broadcast — los frontends ven la run en `<1s`. @@ -223,7 +223,7 @@ Flags del `server`: | Flag | Default | Que | |---|---|---| -| `--port` | 8090 | Puerto HTTP. | +| `--port` | 4200 | Puerto HTTP. | | `--dags-dir` | `apps/dag_engine/dags` (via systemd unit) | Dir scaneado para YAMLs. | | `--db` | `dag_engine.db` | SQLite con `dag_runs` + `dag_step_results`. | | `--scheduler` | false | Si presente, arranca cron tickers automaticamente. | @@ -287,7 +287,7 @@ Flags del `server`: Debes ver `[scheduler] ticker started for (), next: `. 3. Si `next:` es muy lejano (ej. en una semana) y necesitas probar -> dispara manual: ```bash - curl -X POST http://127.0.0.1:8090/api/dags//run + curl -X POST http://127.0.0.1:4200/api/dags//run ``` 4. Hora del sistema descalibrada: ```bash @@ -302,7 +302,7 @@ Flags del `server`: | Causa | Fix | |---|---| | Servidor caido | `systemctl --user status dag_engine.service`, `restart` si `inactive`. | -| Puerto cambiado | El cliente apunta a `127.0.0.1:8090` por codigo (constante `g_ws_port`). Reedificar si cambiaste el puerto del server. | +| Puerto cambiado | El cliente apunta a `127.0.0.1:4200` por codigo (constante `g_ws_port`). Reedificar si cambiaste el puerto del server. | | Firewall Windows -> WSL | WSL2 expone `localhost`, normalmente OK. Si falla: `wsl --shutdown` y reabrir. | ### 5.6. Cleanup de runs viejos diff --git a/apps/dag_engine/app.md b/apps/dag_engine/app.md index 82cbd684..b5a7b32d 100644 --- a/apps/dag_engine/app.md +++ b/apps/dag_engine/app.md @@ -2,7 +2,7 @@ name: dag_engine lang: go domain: infra -version: 0.1.0 +version: 0.2.0 description: "Motor de ejecucion de DAGs del fn_registry: CLI + servidor HTTP + scheduler cron. Schema YAML propio con `function:` para invocar funciones del registry (`fn run `) y `command:` para shell. Historial en SQLite. Scheduler oficial del ecosistema." tags: [service, dag, workflow, scheduler, web, cron] uses_functions: @@ -29,7 +29,7 @@ framework: "net/http + vite + react" entry_point: "main.go" dir_path: "apps/dag_engine" service: - port: 8090 + port: 4200 health_endpoint: /api/dags health_timeout_s: 3 systemd_unit: dag_engine.service @@ -88,13 +88,13 @@ cd .. && CGO_ENABLED=1 go build -tags fts5 -o dag-engine . ./dag-engine list apps/dag_engine/dags/ # Servidor web (production: gestionado por dag_engine.service systemd user unit) -./dag-engine server --port 8090 --dags-dir apps/dag_engine/dags/ --scheduler -# Browser: http://localhost:8090 +./dag-engine server --port 4200 --dags-dir apps/dag_engine/dags/ --scheduler +# Browser: http://localhost:4200 ``` ## Notas -Schema YAML propio (ver `README.md` seccion 3 + ejemplos en `dags/`). Steps tipo `function:` invocan `fn run ` y propagan `function_id` a `dag_step_results` para el bucle reactivo. Puerto default 8090. +Schema YAML propio (ver `README.md` seccion 3 + ejemplos en `dags/`). Steps tipo `function:` invocan `fn run ` y propagan `function_id` a `dag_step_results` para el bucle reactivo. Puerto default 4200. ### 2026-05-16 — Fix function-not-found en steps `function:` + panel Logs en RunDetail `[done]` @@ -141,3 +141,4 @@ Una linea por bump SemVer. Bump-type segun `.claude/commands/version.md`: - `patch`: bugfix sin cambio observable. - v0.1.0 (2026-05-18) — baseline. +- v0.2.0 (2026-06-02) — minor: limpieza de la herencia `dagu` (renombrado `DAGU_ENV`→`FN_DAG_ENV`, directorio `dags_migrated/`→`dags/`, eliminado DAGs legacy/ejemplo), historial de ejecuciones reseteado, frontend reescrito con el estilo fn (tema indigo + radius md + `FnProvider` con `@mantine/notifications`, fix de la API `Collapse in`→`expanded` de Mantine 9.2.1), daemon systemd-user sirviendo React + API en el puerto 4200, y reduccion del binario de ~72MB a ~10MB separando los drivers pesados (duckdb/clickhouse/postgres/matrix/keyring) del paquete `functions/infra` a subpaquetes propios. `go.mod` replace ahora relativo (`../..`). diff --git a/apps/dag_engine/frontend/vite.config.ts b/apps/dag_engine/frontend/vite.config.ts index bd5bbb7c..9ec346db 100644 --- a/apps/dag_engine/frontend/vite.config.ts +++ b/apps/dag_engine/frontend/vite.config.ts @@ -6,7 +6,7 @@ export default defineConfig({ server: { port: 5175, proxy: { - "/api": "http://localhost:8090", + "/api": "http://localhost:4200", }, }, build: {