Skip to content

Commit 7652fbc

Browse files
fix(processor): restore missing update of session
1 parent a55b2f0 commit 7652fbc

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

invokeai/app/services/session_processor/session_processor_default.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -148,6 +148,9 @@ def _on_after_run_session(self, queue_item: SessionQueueItem) -> None:
148148
graph_execution_state_id=queue_item.session.id, output_path=stats_path
149149
)
150150

151+
# Update the queue item with the completed session
152+
self._services.session_queue.set_queue_item_session(queue_item.item_id, queue_item.session)
153+
151154
# Send complete event
152155
self._services.events.emit_graph_execution_complete(
153156
queue_batch_id=queue_item.batch_id,
@@ -399,9 +402,10 @@ def _on_non_fatal_processor_error(
399402
# Non-fatal error in processor
400403
self._invoker.services.logger.error(f"Non-fatal error in session processor: {exc_type.__name__}")
401404
self._invoker.services.logger.error(stacktrace)
402-
# Cancel the queue item
403405
if queue_item is not None:
406+
# Update the queue item with the completed session
404407
self._invoker.services.session_queue.set_queue_item_session(queue_item.item_id, queue_item.session)
408+
# And cancel the queue item with an error
405409
self._invoker.services.session_queue.cancel_queue_item(queue_item.item_id, error=stacktrace)
406410

407411
for callback in self._on_non_fatal_processor_error_callbacks:

0 commit comments

Comments
 (0)