File tree Expand file tree Collapse file tree 2 files changed +308
-123
lines changed
Expand file tree Collapse file tree 2 files changed +308
-123
lines changed Original file line number Diff line number Diff line change @@ -108,24 +108,6 @@ class FinalResultMessage:
108108 result : str
109109 summary : str | None = None
110110
111- @dataclass (slots = True )
112- class HumanFeedback (KernelBaseModel ):
113- """Message containing human feedback on a step."""
114-
115- step_id : Optional [str ] = None
116- plan_id : str
117- session_id : str
118- approved : bool
119- human_feedback : Optional [str ] = None
120- updated_action : Optional [str ] = None
121-
122- @dataclass (slots = True )
123- class HumanClarification (KernelBaseModel ):
124- """Message containing human clarification on a plan."""
125-
126- plan_id : str
127- session_id : str
128- human_clarification : str
129111
130112@dataclass (slots = True )
131113class ApprovalRequest (KernelBaseModel ):
@@ -155,19 +137,3 @@ class WebsocketMessageType(str, Enum):
155137 USER_CLARIFICATION_REQUEST = "user_clarification_request"
156138 USER_CLARIFICATION_RESPONSE = "user_clarification_response"
157139 FINAL_RESULT_MESSAGE = "final_result_message"
158-
159-
160- @dataclass (slots = True )
161- class WebsocketMessage :
162- """Generic WebSocket message wrapper."""
163- type : WebsocketMessageType
164- message : Any
165- data : Any
166-
167- def to_dict (self ) -> Dict [str , Any ]:
168- """Convert the WebsocketMessage to a dictionary for JSON serialization."""
169- return {
170- "type" : self .type ,
171- "data" : self .data .to_dict () if hasattr (self .data , 'to_dict' ) else self .data ,
172- "message" : self .message .to_dict () if hasattr (self .message , 'to_dict' ) else self .message
173- }
You can’t perform that action at this time.
0 commit comments