A tech stack agnostic Event Driven Workflow framework, written in Go, that supports durable, robust, and idempotent state changes with timeouts, callbacks, scheduled triggers, and await calls. Compatible with Kafka and Reflex out of the box.
This MR / PR focuses on adding the ability to write a short hand consumer for RunState changes. This was always possible before but would require the user to use the correct topic setup or if using Reflex using a StreamFunc to stream and filter by RunState. These are simpler and more discoverable being part of the builder and does not extend the feature set but rather enhances the discoverability of what already exists.
This MR / PR focuses on adding the ability to write a short hand consumer for RunState changes. This was always possible before but would require the user to use the correct topic setup or if using Reflex using a StreamFunc to stream and filter by RunState. These are simpler and more discoverable being part of the builder and does not extend the feature set but rather enhances the discoverability of what already exists.