@@ -121,7 +121,8 @@ def emit_invocation_error(
121
121
node : dict ,
122
122
source_node_id : str ,
123
123
error_type : str ,
124
- error : str ,
124
+ error_message : str ,
125
+ error_traceback : str ,
125
126
user_id : str | None ,
126
127
project_id : str | None ,
127
128
) -> None :
@@ -136,7 +137,8 @@ def emit_invocation_error(
136
137
"node" : node ,
137
138
"source_node_id" : source_node_id ,
138
139
"error_type" : error_type ,
139
- "error" : error ,
140
+ "error_message" : error_message ,
141
+ "error_traceback" : error_traceback ,
140
142
"user_id" : user_id ,
141
143
"project_id" : project_id ,
142
144
},
@@ -257,7 +259,9 @@ def emit_queue_item_status_changed(
257
259
"status" : session_queue_item .status ,
258
260
"batch_id" : session_queue_item .batch_id ,
259
261
"session_id" : session_queue_item .session_id ,
260
- "error" : session_queue_item .error ,
262
+ "error_type" : session_queue_item .error_type ,
263
+ "error_message" : session_queue_item .error_message ,
264
+ "error_traceback" : session_queue_item .error_traceback ,
261
265
"created_at" : str (session_queue_item .created_at ) if session_queue_item .created_at else None ,
262
266
"updated_at" : str (session_queue_item .updated_at ) if session_queue_item .updated_at else None ,
263
267
"started_at" : str (session_queue_item .started_at ) if session_queue_item .started_at else None ,
0 commit comments