Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
37 commits
Select commit Hold shift + click to select a range
1ad7ec7
feat: replace gov-relay service with logs JSONL + Redis transport
timzsu Apr 29, 2026
666f13f
chore: regenerate service requirements with redis on worker-core
timzsu Apr 29, 2026
af4ce7e
fix: end-to-end e2e bring-up — gating, transport, paths, analyzer
timzsu Apr 29, 2026
8149f15
refactor(profile): align analyzer with lumilake's e2e + critical_path…
timzsu Apr 29, 2026
186c324
feat(profile): rich CLI rendering, SDK dataframe helpers
timzsu Apr 29, 2026
c9a8136
refactor(profile cli): split format options; rename "Hardware" → "Com…
timzsu Apr 29, 2026
83b3af7
style: black formatting
timzsu Apr 29, 2026
a9f019d
refactor(worker): make Redis a cache layer with server fallback
timzsu Apr 29, 2026
d9ee286
style: top-level imports + drop unused params
timzsu Apr 29, 2026
37c44d8
refactor(profile): emit OTel-shaped spans, derive per-data_id queuing…
timzsu Apr 30, 2026
966af69
fix(spans): preserve trace context in thread pool, flush root before …
timzsu Apr 30, 2026
d91bce3
docs(agents): require image rebuild before any e2e validation round
timzsu Apr 30, 2026
97f425f
refactor(spans): type kind as FlowMeshSpanKind enum, drop string lite…
timzsu Apr 30, 2026
76cb3a5
refactor(worker): route data cache through supervisor; drop redis dep
timzsu Apr 30, 2026
5861915
refactor(spans): collapse markers into spans where work has duration
timzsu Apr 30, 2026
01eea33
chore: drop unused fakeredis dev dep
timzsu Apr 30, 2026
0dd702c
refactor(worker): defer Redis result cache to a follow-up branch
timzsu Apr 30, 2026
5895669
docs(agents): require PR-specific --image-tag for stack builds
timzsu Apr 30, 2026
e8ab664
refactor(cli): strict view enum, drop redundant casts and inline imports
timzsu Apr 30, 2026
7d289e5
refactor: drop redundant list() copies in lineage paths
timzsu Apr 30, 2026
a752d37
style: defensive copies use .copy() instead of constructor calls
timzsu Apr 30, 2026
283abfb
docs(agents): correct PR-specific image-tag rule
timzsu Apr 30, 2026
dc2913d
docs(agents): simplify PR-image-tag rule to .env-only
timzsu Apr 30, 2026
e54c9e1
refactor(trace): unify logs+profile into trace, scope to governance only
timzsu May 1, 2026
6e6fa36
refactor(trace): drop spec.governance and dead redis_keys helpers
timzsu May 1, 2026
bdd9a69
refactor(trace): unify HardwareSummary+NetworkSummary; rename _write_…
timzsu May 1, 2026
87b8ee2
refactor(spans): nest context/status/attributes as their own pydantic…
timzsu May 1, 2026
a049092
refactor(mixins): split governance row writes back into GovernanceMixin
timzsu May 1, 2026
d11ee2d
refactor(trace): address review — repackage, /trace router, upload + …
timzsu May 2, 2026
be8d28d
refactor(trace): address review — pluralize endpoint, inline jsonl, t…
timzsu May 2, 2026
615eaaf
refactor(trace): rename FlowMeshSpanKind to SpanType; align singular/…
timzsu May 2, 2026
d82aeb9
refactor(trace): rename shared/schemas/spans.py to governance.py
timzsu May 2, 2026
202ece5
refactor(trace): per-task trace upload via POST /traces/{task_id}/{type}
timzsu May 2, 2026
202025b
refactor(trace): simplify maybe_upload_traces, drop helper + module c…
timzsu May 2, 2026
4a942fc
refactor(trace): nest trace endpoints under /workflows/ and /tasks/, …
timzsu May 2, 2026
1d3af19
test(sdk): add round-trip tests for trace analyzer payload models
timzsu May 2, 2026
f6a0040
refactor(tests): move server model definitions to the top of the file
kaiitunnz May 2, 2026
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
1 change: 1 addition & 0 deletions cli/pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@ requires-python = ">=3.12"
dependencies = [
"typer>=0.12.5",
"pyyaml>=6.0.2",
"rich>=14.2.0",
"websockets>=15.0",
"flowmesh-sdk>=0.1.0",
]
Expand Down
2 changes: 2 additions & 0 deletions cli/src/flowmesh_cli/commands/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@
from .ssh import app as ssh_app
from .system import app as system_app
from .task import app as task_app
from .trace import app as trace_app
from .worker import app as worker_app
from .workflow import app as workflow_app

Expand All @@ -22,3 +23,4 @@ def register(app: typer.Typer) -> None:
app.add_typer(node_app, name="node")
app.add_typer(worker_app, name="worker")
app.add_typer(ssh_app, name="ssh")
app.add_typer(trace_app, name="trace")
Loading