@@ -127,11 +127,9 @@ def run_node(self, invocation: BaseInvocation, queue_item: SessionQueueItem):
127
127
pass
128
128
except Exception as e :
129
129
# Must extract the exception traceback here to not lose its stacktrace when we change scope
130
- exc_type = type (e )
131
- exc_value = e
132
130
exc_traceback = e .__traceback__
133
131
assert exc_traceback is not None
134
- self ._on_node_error (invocation , queue_item , exc_type , exc_value , exc_traceback )
132
+ self ._on_node_error (invocation , queue_item , type ( e ), e , exc_traceback )
135
133
136
134
def _on_before_run_session (self , queue_item : SessionQueueItem ) -> None :
137
135
# If profiling is enabled, start the profiler
@@ -212,7 +210,7 @@ def _on_node_error(
212
210
213
211
queue_item .session .set_node_error (invocation .id , stacktrace )
214
212
self ._services .logger .error (
215
- f"Error while invoking session { queue_item .session_id } , invocation { invocation .id } ({ invocation .get_type ()} ):\n { exc_type } "
213
+ f"Error while invoking session { queue_item .session_id } , invocation { invocation .id } ({ invocation .get_type ()} ): { exc_type . __name__ } "
216
214
)
217
215
self ._services .logger .error (stacktrace )
218
216
@@ -374,11 +372,9 @@ def _process(
374
372
375
373
except Exception as e :
376
374
# Must extract the exception traceback here to not lose its stacktrace when we change scope
377
- exc_type = type (e )
378
- exc_value = e
379
375
exc_traceback = e .__traceback__
380
376
assert exc_traceback is not None
381
- self ._on_non_fatal_processor_error (self ._queue_item , exc_type , exc_value , exc_traceback )
377
+ self ._on_non_fatal_processor_error (self ._queue_item , type ( e ), e , exc_traceback )
382
378
# Immediately poll for next queue item
383
379
poll_now_event .wait (self ._polling_interval )
384
380
continue
@@ -401,7 +397,8 @@ def _on_non_fatal_processor_error(
401
397
) -> None :
402
398
stacktrace = get_stacktrace (exc_type , exc_value , exc_traceback )
403
399
# Non-fatal error in processor
404
- self ._invoker .services .logger .error (f"Non-fatal error in session processor:\n { stacktrace } " )
400
+ self ._invoker .services .logger .error (f"Non-fatal error in session processor: { exc_type .__name__ } " )
401
+ self ._invoker .services .logger .error (stacktrace )
405
402
# Cancel the queue item
406
403
if queue_item is not None :
407
404
self ._invoker .services .session_queue .cancel_queue_item (queue_item .item_id , error = stacktrace )
0 commit comments