umh-core
v0.44.22
v0.44.22
Improvements
- Sparkplug B input:
request_birth_on_connectnow defaults totrue, sosecondary_active/primarybridges proactively rebirth newly seen nodes on connect. Set it tofalseto keep the prior behavior (ignored undersecondary_passive) - Sparkplug B input: field descriptions and the primary-role startup log now clarify that
identity.edge_node_idis the Sparkplug v3.0-compatiblehost_idin the STATE topic (spBv1.0/STATE/<host_id>) - New
snowflake_putoutput: ports the warpstreamlabs/bento Snowflake output into benthos-umh for writing batched messages to Snowflake stages with optional Snowpipe ingestion. Supports user/password and key-pair auth, all gosnowflake compression modes, and per-message stage/Snowpipe interpolation
Fixes
- When an FSMv2 transport worker (auth, push, or pull) was stuck in a transient-retry state, the supervisor heartbeat printed the same stale reason set on entry — for example
"Desired state is running, transitioning to Starting"— instead of the live per-tick reason the worker already composes, such as"auth backoff: 42 errors (cloudflare_challenge), delay 60s". The heartbeat now surfaces the live reason within one ~10s cycle. - Sparkplug B input:
identity.group_idnow filters the MQTT subscription by default. Previously an emptysubscription.groupssubscribed to every Sparkplug group on the broker (spBv1.0/+/#) regardless ofidentity.group_id. To restore the old behavior, setsubscription.groups: ["+"]explicitly - Sparkplug B input: bridges now request a rebirth when DATA references aliases the cache hasn't seen (typically after a bridge restart with no retained
NBIRTH/DBIRTHon the broker). Previously tags surfaced as…/_historian/alias_<n>until something external triggered recovery
Preview: Write Flows
- Write flows (preview) now take their input topics directly on the flow, with Go template support for values like
{{ .location_path }}. Write flows configured on this preview before this release are not carried over and need to be re-created from the UI; read flows and connection settings are unaffected