Skip to content

Conversation

@vertefra
Copy link
Contributor

@vertefra vertefra commented Dec 2, 2025

  • Add NodeMessage type with nodeID, message, timestamp, level, and data fields
  • Add streamChannel field to BaseGraphState (send-only channel)
  • Add StreamMessage() and StreamMessageWithLevel() helper methods
  • Add RunStream() method to GGraph for streaming execution
  • Keep Run() method unchanged for backward compatibility
  • Add example demonstrating streaming functionality

- Add NodeMessage type with nodeID, message, timestamp, level, and data fields
- Add streamChannel field to BaseGraphState (send-only channel)
- Add StreamMessage() and StreamMessageWithLevel() helper methods
- Add RunStream() method to GGraph for streaming execution
- Keep Run() method unchanged for backward compatibility
- Add example demonstrating streaming functionality
…ty function

- Create ExtractNodeComponents utility function in workflows/utils.go
- Refactor conversationNode to use the new utility function
- Centralize state value extraction for reuse across workflow nodes
- Remove duplicate extraction logic and unused imports
- Update handlers, app, and ggraph state management
- Integrate workflow system with existing components
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants