revert context indent change between rpc caller and try-except

src/ai/backend/manager/registry.py

@@ -1824,10 +1824,39 @@ async def _update_failure() -> None:
                                 status_data=err_info,
                             )
                         )
-                        await db_sess.execute(query)
 
-                await execute_with_retry(_update_failure)
-            raise
+                # The agent has already cancelled or issued the destruction lifecycle event
+                # for this batch of kernels.
+                for binding in items:
+                    kernel_id = binding.kernel.id
+
+                    async def _update_failure() -> None:
+                        async with self.db.begin_session() as db_sess:
+                            now = datetime.now(tzutc())
+                            query = (
+                                sa.update(KernelRow)
+                                .where(KernelRow.id == kernel_id)
+                                .values(
+                                    status=KernelStatus.ERROR,
+                                    status_info=f"other-error ({ex!r})",
+                                    status_changed=now,
+                                    terminated_at=now,
+                                    status_history=sql_json_merge(
+                                        KernelRow.status_history,
+                                        (),
+                                        {
+                                            KernelStatus.ERROR.name: (
+                                                now.isoformat()
+                                            ),  # ["PULLING", "PREPARING"]
+                                        },
+                                    ),
+                                    status_data=err_info,
+                                )
+                            )
+                            await db_sess.execute(query)
+
+                    await execute_with_retry(_update_failure)
+                raise
 
     async def create_cluster_ssh_keypair(self) -> ClusterSSHKeyPair:
         key = rsa.generate_private_key(