Proto commits in littlehorse-enterprises/littlehorse

These commits are when the Protocol Buffers files have changed: (only the last 100 relevant commits are shown)

2026-10-01

Add structdef id for user task runs

2026-09-30

feat(api): support struct-backed user tasks

2026-09-24

Merge remote-tracking branch 'origin/master' into feat/sdk-java/support-records # Conflicts: # sdk-java/src/main/java/io/littlehorse/sdk/common/LHLibUtil.java # sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/internal/structdefutil/LHClassType.java # sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/internal/structdefutil/LHStructProperty.java # sdk-java/src/test/java/io/littlehorse/sdk/common/LHLibUtilTest.java # sdk-java/src/test/java/io/littlehorse/sdk/wfsdk/internal/structdefutil/LHClassTypeTest.java # sdk-java/src/test/java/io/littlehorse/sdk/wfsdk/internal/structdefutil/LHStructDefTypeTest.java

2026-09-22

feat(api): support struct-backed user tasks

2026-09-04

feat(server): add SearchWorkflowMigrationPlan RPC and lhctl support (#2461)

feat(sdk-java): add Map `put` and `LHMapBuilder` semantics (#2443) * feat(proto): add MapBuilder support for inline map construction * shorten proto comment rebuild proto * feat(sdk-java): add map.put(key, value) DSL and LHMapBuilder * update map proposal * update map example to be more practical * feat(proto): add MapBuilder support for inline map construction * shorten proto comment rebuild proto * feat(sdk-java): add map.put(key, value) DSL and LHMapBuilder * update map proposal * update map example to be more practical * feat(sdk-java): add map.put(key, value) DSL and LHMapBuilder * update map proposal * update map example to be more practical * fix(server): require map type on ingress * refactor: remove WfRunVariable.put(k,v) from public interface * handle nulls in mapworker * spotless apply * improve map example * feat(proto): add MapBuilder support for inline map construction * shorten proto comment rebuild proto * feat(proto): add MapBuilder support for inline map construction * shorten proto comment rebuild proto * fix(server): require map type on ingress * handle nulls in mapworker * spotless apply * improve map example * refactor map builder model * add test coverage * feat(proposal): update maps proposal * update proto * feat(sdk-java): add new dynamic get and put * feat(examples): update java example * feat(server): add new dynamic get and put functionality * fix map example * add lhs LH Paths and dynamic paths to dashboard * fix proposal * run spotless on server * fix(dashboard): move old lhpath tests to variables test * fix(dashboard): update VariableMutationType to display enum name

feat(server): thread run queue (#2379)

2026-09-03

Merge remote-tracking branch 'origin/master' into feat/thread-run-queue

feat(server): track quota usage in a grpc-facing metric (#2467)

feat: allow setting child wfrun id in RunChildWfNode (#2502) Closes #2501

feat(server): thread run queue

2026-09-02

Merge branch 'master' into feat/metrics-for-quotas

Merge branch 'master' into feat/workflow-migration-plan-search

Merge remote-tracking branch 'origin/master' into feat/thread-run-queue

2026-09-01

update proto

feat(proto): add MapBuilder support for inline map construction (#2442) * feat(proto): add MapBuilder support for inline map construction * shorten proto comment rebuild proto * feat(proto): add MapBuilder support for inline map construction * shorten proto comment rebuild proto * fix(server): require map type on ingress * handle nulls in mapworker * spotless apply * improve map example * fix(dashboard): prevent sidebar crash from stale attempt/noderun index (#2447) * chore(dashboard): migrate to Next.js 16 and React 19 (#2419) * build(deps): bump @opentelemetry/core from 1.30.1 to 2.8.0 in /dashboard (#2458) Bumps [@opentelemetry/core](https://github.com/open-telemetry/opentelemetry-js) from 1.30.1 to 2.8.0. - [Release notes](https://github.com/open-telemetry/opentelemetry-js/releases) - [Changelog](https://github.com/open-telemetry/opentelemetry-js/blob/main/CHANGELOG.md) - [Commits](https://github.com/open-telemetry/opentelemetry-js/compare/v1.30.1...v2.8.0) --- updated-dependencies: - dependency-name: "@opentelemetry/core" dependency-version: 2.8.0 dependency-type: direct:production ... Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> * feat(ci): generate GitHub release notes from release_notes/ instead of git-cliff (#2456) * fix(sdk-java): catch nulls on Task Worker PollTask serialization (#2457) * fix(dashboard): enforce required variables in the execute wfrun form (#2460) * fix(dashboard): default WfRun diagram to the entrypoint threadrun (#2463) * refactor(dashboard): change node that starts workflows to be a box (#2470) fixes #2464 * perf(server): warm RocksDB block cache before forwarding bulk WfRun deletes (#2473) * build(deps-dev): bump postcss from 8.5.18 to 8.5.23 in /dashboard (#2474) Bumps [postcss](https://github.com/postcss/postcss) from 8.5.18 to 8.5.23. - [Release notes](https://github.com/postcss/postcss/releases) - [Changelog](https://github.com/postcss/postcss/blob/main/CHANGELOG.md) - [Commits](https://github.com/postcss/postcss/compare/8.5.18...8.5.23) --- updated-dependencies: - dependency-name: postcss dependency-version: 8.5.23 dependency-type: direct:development ... Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> * build(deps): bump postcss from 8.4.31 to 8.5.26 in /dashboard (#2476) Bumps [postcss](https://github.com/postcss/postcss) from 8.4.31 to 8.5.26. - [Release notes](https://github.com/postcss/postcss/releases) - [Changelog](https://github.com/postcss/postcss/blob/main/CHANGELOG.md) - [Commits](https://github.com/postcss/postcss/compare/8.4.31...8.5.26) --- updated-dependencies: - dependency-name: postcss dependency-version: 8.5.26 dependency-type: indirect ... Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> * build(deps): bump @opentelemetry/core from 2.8.0 to 2.9.0 in /dashboard (#2477) Bumps [@opentelemetry/core](https://github.com/open-telemetry/opentelemetry-js) from 2.8.0 to 2.9.0. - [Release notes](https://github.com/open-telemetry/opentelemetry-js/releases) - [Changelog](https://github.com/open-telemetry/opentelemetry-js/blob/main/CHANGELOG.md) - [Commits](https://github.com/open-telemetry/opentelemetry-js/compare/v2.8.0...v2.9.0) --- updated-dependencies: - dependency-name: "@opentelemetry/core" dependency-version: 2.10.0 dependency-type: indirect ... Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> * build(deps): bump next-auth from 4.24.14 to 4.24.15 in /dashboard (#2475) Co-authored-by: bryson-g <114206517+bryson-g@users.noreply.github.com> * build(deps): update js-yaml transitive dependencies (#2478) * feat(proposals): Add StructFieldDef Descriptions proposal (#2462) * build(deps): bump opentelemetry prometheus exporter in /dashboard (#2479) Upgrade the Prometheus exporter to 0.220.0 and align resources and sdk-metrics on 2.9.0 to address the Dependabot vulnerability. Migrate resource initialization to the OpenTelemetry 2.x APIs. Assisted-by: GPT-5.6 Sol * build(deps): bump @opentelemetry/core in /dashboard (#2483) Bumps [@opentelemetry/core](https://github.com/open-telemetry/opentelemetry-js) from 1.30.1 to 2.10.0. - [Release notes](https://github.com/open-telemetry/opentelemetry-js/releases) - [Changelog](https://github.com/open-telemetry/opentelemetry-js/blob/main/CHANGELOG.md) - [Commits](https://github.com/open-telemetry/opentelemetry-js/compare/v1.30.1...v2.10.0) --- updated-dependencies: - dependency-name: "@opentelemetry/core" dependency-version: 2.10.0 dependency-type: indirect ... Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> * fix(dashboard): end the keycloak session when signing out (#2481) * build(deps): bump golang.org/x/net from 0.47.0 to 0.55.0 and Go to from 1.24.4 to 1.25.14 (#2484) * build(deps): bump golang.org/x/net from 0.47.0 to 0.55.0 Bumps [golang.org/x/net](https://github.com/golang/net) from 0.47.0 to 0.55.0. - [Commits](https://github.com/golang/net/compare/v0.47.0...v0.55.0) --- updated-dependencies: - dependency-name: golang.org/x/net dependency-version: 0.55.0 dependency-type: indirect ... Signed-off-by: dependabot[bot] <support@github.com> * build(go): align toolchain with Go 1.25 requirement - pin the root and lhctl toolchains to Go 1.25.14 - update CI, release, Docker, and protobuf builds for Go 1.25 - update lhctl transitive Go dependencies - document the Go 1.25 minimum requirement Assisted-by: GPT-5.6 Sol * remove 1.27 from test --------- Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: JakeRose03 <jake.rose8@icloud.com> Co-authored-by: Jake-R <jaker6225@gmail.com> * build(deps): bump google.golang.org/grpc from 1.66.0 to 1.82.1 (#2482) Bumps [google.golang.org/grpc](https://github.com/grpc/grpc-go) from 1.66.0 to 1.82.1. - [Release notes](https://github.com/grpc/grpc-go/releases) - [Commits](https://github.com/grpc/grpc-go/compare/v1.66.0...v1.82.1) --- updated-dependencies: - dependency-name: google.golang.org/grpc dependency-version: 1.82.1 dependency-type: direct:production ... Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> * build(deps): upgrade OpenTelemetry HTTP instrumental to fix transitive dependency vulnerability (#2489) * build(deps): pin post css to 8.5.10 or greater (#2490) * build(deps): bump google.golang.org/grpc from 1.79.3 to 1.82.1 in /lhctl (#2492) Bumps [google.golang.org/grpc](https://github.com/grpc/grpc-go) from 1.79.3 to 1.82.1. - [Release notes](https://github.com/grpc/grpc-go/releases) - [Commits](https://github.com/grpc/grpc-go/compare/v1.79.3...v1.82.1) --- updated-dependencies: - dependency-name: google.golang.org/grpc dependency-version: 1.82.1 dependency-type: direct:production ... Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> * build(deps): pin brand-expansion ^1.1.16 (#2493) * build(deps): bump js-yaml to (#2494) * build(deps): upgrade brace in sdk-js (#2497) * feat: add StructFieldDef descriptions (#2485) * feat(proto): add MapBuilder support for inline map construction * shorten proto comment rebuild proto * feat(proto): add MapBuilder support for inline map construction * shorten proto comment rebuild proto * fix(server): require map type on ingress * handle nulls in mapworker * spotless apply * improve map example * refactor map builder model * add test coverage --------- Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: bryson-g <114206517+bryson-g@users.noreply.github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Eduwer Camacaro <eduwerc@gmail.com> Co-authored-by: Colt McNealy <colt@littlehorse.io> Co-authored-by: Jake-R <jaker6225@gmail.com> Co-authored-by: JakeRose03 <jake.rose8@icloud.com>

feat: allow setting child wfrun id in RunChildWfNode

2026-08-27

fix(server): require map type on ingress

shorten proto comment rebuild proto

feat(proto): add MapBuilder support for inline map construction

shorten proto comment rebuild proto

feat(proto): add MapBuilder support for inline map construction

feat: add StructFieldDef descriptions (#2485)

2026-08-20

feat: add StructFieldDef descriptions

2026-08-16

feat(server): track quota usage in a grpc-facing metric

2026-08-12

feat(server): add SearchWorkflowMigrationPlan RPC and lhctl support

2026-08-05

fix(server): require map type on ingress

2026-08-04

shorten proto comment rebuild proto

feat(proto): add MapBuilder support for inline map construction

2026-07-30

shorten proto comment rebuild proto

feat(proto): add MapBuilder support for inline map construction

2026-07-14

feat(server): workflow-migrations (#2336) Allow wfRun instances to migrate to new wfSpec Versions

2026-07-13

feat(server): workflow-migrations (#2336) Allow wfRun instances to migrate to new wfSpec Versions

2026-07-10

feat(server): bulk-delete WfRuns via BulkJob (#2370) Adds a first-class BulkJob mechanism whose first operation is bulk deletion of WfRuns. Deletion runs in the background, sharded per partition, without ever blocking Kafka Streams on a large transaction. Also adds SearchBulkJob (filter by status) and DeleteBulkJob (for finished jobs).

2026-07-09

experimental flag

Merge branch 'master' into feat/workflow-migrations

2026-07-08

change inactive_thread_run_type to inactive_reason

2026-07-07

Merge branch 'master' into feat-bulk-job-proposal

feat(server): add LittleHorse Native Maps (#2368)

Merge branch 'master' into feat-bulk-job-proposal

2026-07-06

Merge branch 'master' into feat/add-maps-to-lh

Merge remote-tracking branch 'origin/master' into feat/workflow-migrations

2026-07-05

search and get bulk jobs

2026-07-01

Merge remote-tracking branch 'origin/master' into feat/thread-run-queue

2026-06-30

feat(server): thread run queue

feat(proto): add `InlineStructDef` type to `TypeDefinition` (#2257)

track of the last seen timestamp

2026-06-29

fix ambigous field "dependencies" and remove unnecassary comments

Merge branch 'master' into feat/proto/add-inlinestructdef-to-typedef

2026-06-25

Refactor proposal

feat(proto): add maps

2026-06-22

Workflow Migrations: rpc applyWorkflowMIgrationPlan, putWorkflowMigrationPlan, getWorkflowMIgrationPlan

2026-06-17

Track progress of a bulk job

2026-06-11

refactors

2026-06-10

Switch to node_migrations

2026-06-07

Create models for bulk job wfrun delete

Initial implementation

2026-06-03

Merge remote-tracking branch 'origin/master' into feat/workflow-migrations

rpc putWorkflowMigrationPlan, applyWorkflowMigrationPlan, GetWorkflowMIgrationPlan

2026-06-01

feat(server): Count all the NodeRun in a tenant (#2304) Extends the counted-tag proposal to include the ability to count the number of NodeRun on a single tenant.

2026-05-27

Register workflowmigration Plan with lh server and some implementation for applyworkflowmigration

2026-05-26

feat(server): Add counted tags to the existing Tag architecture (#2265) Implement proposal 021 for counted tags.

2026-05-20

feat(dashboard): overhaul WfSpec detail page layout and metadata Redesign the WfSpec header, thread selector, and thread details sections for clearer navigation and add CountNodeRun storage usage support.

2026-05-19

ci(snapshots): publish snapshots for minor versions (#2278) Adds a new `publish-snapshots` workflow that publishes both Java and Docker SNAPSHOT artifacts on pushes to `master` and release branches (e.g., `1.1`). The snapshot version is computed from `gradle.properties` by extracting only the `major.minor` portion: - `master` (`version=1.2.0-SNAPSHOT`) → publishes `1.2-SNAPSHOT` - `1.1` branch (`version=1.1.1-SNAPSHOT`) → publishes `1.1-SNAPSHOT` Co-authored-by: Eduwer Camacaro <eduwerc@gmail.com>

ci(snapshots): publish snapshots for minor versions (#2278) Adds a new `publish-snapshots` workflow that publishes both Java and Docker SNAPSHOT artifacts on pushes to `master` and release branches (e.g., `1.1`). The snapshot version is computed from `gradle.properties` by extracting only the `major.minor` portion: - `master` (`version=1.2.0-SNAPSHOT`) → publishes `1.2-SNAPSHOT` - `1.1` branch (`version=1.1.1-SNAPSHOT`) → publishes `1.1-SNAPSHOT` Co-authored-by: Eduwer Camacaro <eduwerc@gmail.com>

2026-05-06

feat(proto): add InlineStructDef to TypeDef defined_type

2026-04-29

feat(server): add POW operation to WfSpec DSL (#2243)

2026-04-27

feat(server): implement `Quota` proposal (#2141) - Creates `rpc PutQuota`, `rpc DeleteQuota`, `rpc GetQuota`, and `rpc SearchQuota` - Adds intelligent server-side throttling with `RESOURCE_EXHAUSTED` - Adds client interceptors to gracefully wait and then retry upon `RESOURCE_EXHAUSTED` - Introduces `LHC_GRPC_RESOURCE_EXHAUSTED_RETRY` configuration

2026-04-24

feat(server): add SizeOf unary operation for Strs, Arrays, JsonArrs (#2230)

2026-04-23

feat(server): allows building structs inside the wfspec dsl (#2224) - Adds `StructBuilder` option to `VariableAssignment` - Implements it in the Java SDK

2026-04-17

feat(server): add `is_nullable` flag for StructFieldDefs (#2215)

2026-04-15

feat(server): GetMetricWindow and SearchWfMetricWindow RPCs (#2204) Metrics now support tags for easier searching. Added `GetMetricWindow` to fetch a metric window by ID and `SearchWfMetricWindow` to find workflow metric windows by name and optional time range.

2026-04-14

feat(server): Tenant aggregated metrics (#2171) Adds tenant-level aggregated metrics alongside existing workflow/task metrics. Each punctuator now produces both scoped and global aggregations, enabling queries that return totals across all workflows or tasks.

2026-04-01

feat(server): Add native `ARRAY` type (#2179)

2026-03-24

feat(server): Workflow metrics (#2071) Adds workflow and task metrics to the server. Metrics are collected per WfSpec and per TaskDef in 1-minute windows and exposed via a gRPC RPC to query metrics for a specific WfSpec or TaskDef.

2026-03-11

docs(proto): add comments to all RPCs, Messages, Enums (#2140)

docs(proto): add comments to all RPCs, Messages, Enums (#2140)

2026-03-06

fix(server): fix and refactor Struct field masking (#2101)

feat(server): Edge condition refactor (#2080)

2026-03-03

feat(server): Archive Inactive ThreadRuns (#2044)

2026-02-24

fix(server): Fix pagination for List rpc (#2027)

2026-02-13

feat(server): allow waking up parent wfRun when child is rescued (#2074)

2026-02-12

First iteration: -Add new proto structures - Remove dependency for WorkflowCondition

2026-02-10

migrations

2026-02-06

feat(server): Support using WfRunVariable as input for RunChildWfNode (#2045) This PR extends the RunChildWfNode to support using WfRunVariable as the WfSpec name when running a child workflow. This allows the child WfSpec to be determined dynamically at runtime instead of being fully specified at WfSpec compile time. Changes include: Support for resolving the child WfSpec from a VariableAssignment instead of only from a static RunChildWfNode .wfSpecName. New backward compatible field for RunChildWfNode Existing behavior using a static wfSpecName continues to work unchanged. Validation of child workflow inputs/outputs is not executed at WfSpec compile time when the spec is provided dynamically.

2026-02-04

fix(server): save timer iterator progress and isolate timers (#2042) This PR fixes two problems with the Timer Processor in the core topology. - We iterate from the beginning of the timer store in the first punctuation. When creating a new processor (eg. after a rebalance) that involves iterating over tombstones, and that has been observed to take more than 60 seconds, which increases our downtime window. - We were not isolating LHTimer's with the Storeable infrastructure but rather storing them as if they were the only thing in the core store. Thus when we put something inside the cluster-scoped store, we get problems as the timer iterator sees those things as timers. We'll also need to guard the Tenant names to prevent them from starting with a digit, as that could result stuff in the tenant-scoped stores being mistaken for a cluster-scoped timer. This PR also disables the timer topology by default.

2026-01-26

fix(server): save timer iterator progress and isolate timers (#2042) This PR fixes two problems with the Timer Processor in the core topology. - We iterate from the beginning of the timer store in the first punctuation. When creating a new processor (eg. after a rebalance) that involves iterating over tombstones, and that has been observed to take more than 60 seconds, which increases our downtime window. - We were not isolating LHTimer's with the Storeable infrastructure but rather storing them as if they were the only thing in the core store. Thus when we put something inside the cluster-scoped store, we get problems as the timer iterator sees those things as timers. We'll also need to guard the Tenant names to prevent them from starting with a digit, as that could result stuff in the tenant-scoped stores being mistaken for a cluster-scoped timer. This PR also disables the timer topology by default.

Merge branch 'master' into fix/threadruns-archive

Merge branch 'feature/archive-threadruns' into fix/threadruns-archive

2026-01-25

feat(server): allow different strategies in `WaitForThreadsNode` (#2040) Implements #2037 according to Proposal 13.

2026-01-23

feat(proto): add inactivethreadrun proto

2026-01-09

remove unused proto / mock rpc getarchivedthreadrun

2026-01-07

Merge branch 'master' into fix/threadruns-archive

2026-01-05

Merge branch 'master' into metrics

refactor(server): Remove timer topology (#1979) Introduces ServerTopologyV2, unifying core logic and timer processing into a single Kafka Streams topology behind the LHS_X_ENABLE_TIMER_STREAMS feature flag. This removes the separate timer topology, reducing operational complexity, resource usage, and inter-topic communication. Timers are stored and executed within the core pipeline using a shared state store with smart routing and repartitioning only when required.

2025-12-22

feat(sdk-java): add description to LHTaskMethod annotation (#1989)

fix(server): Improve how node outputs are retrieved (#1975) This PR adds a new NODE_OUTPUT storeable that saves node outputs by node name, enabling direct and faster retrieval. Only outputs from nodes referenced in the thread spec are stored to optimize storage. Backward compatibility is preserved by falling back to the legacy backward lookup for existing workflows.

feat(server): add descriptions to TaskDefs (#1990)

2025-12-19

add migration variables to proto, allow migration request to provide variableValues

2025-12-17

Init rough draft, base case migrates, still need variables and threading