ci: retrigger

Author: nicoloboschi

hindsight-api-slim/hindsight_api/engine/memory_engine.py

@@ -3828,9 +3828,13 @@ async def delete_memory_unit(
 
         if bank_id_for_consolidation:
             try:
-                await self.submit_async_consolidation(bank_id=bank_id_for_consolidation, request_context=request_context)
+                await self.submit_async_consolidation(
+                    bank_id=bank_id_for_consolidation, request_context=request_context
+                )
             except Exception as e:
-                logger.warning(f"Failed to submit consolidation after memory deletion for bank {bank_id_for_consolidation}: {e}")
+                logger.warning(
+                    f"Failed to submit consolidation after memory deletion for bank {bank_id_for_consolidation}: {e}"
+                )
 
         return result
 

hindsight-api-slim/tests/test_retain.py

@@ -1103,13 +1103,12 @@ async def test_document_upsert_behavior(memory, request_context):
 
         assert len(v2_units) > 0, "Should create units for v2"
 
-        # Recall should return the updated information
+        # Recall should return the updated information (no fact_type filter — LLM may classify as world or experience)
         result = await memory.recall_async(
             bank_id=bank_id,
             query="What is the project status?",
             budget=Budget.MID,
             max_tokens=1000,
-            fact_type=["world"],
             request_context=request_context,
         )
 

hindsight-api-slim/tests/test_worker.py

@@ -952,8 +952,8 @@ async def mock_executor(task_dict):
         assert executed[0] == task_dict
 
     @pytest.mark.asyncio
-    async def test_sync_backend_handles_errors(self):
-        """Test that SyncTaskBackend handles executor errors gracefully."""
+    async def test_sync_backend_propagates_errors(self):
+        """Test that SyncTaskBackend propagates executor errors instead of swallowing them."""
 
         async def failing_executor(task_dict):
             raise ValueError("Test error")
@@ -962,8 +962,9 @@ async def failing_executor(task_dict):
         backend.set_executor(failing_executor)
         await backend.initialize()
 
-        # Should not raise, error is logged
-        await backend.submit_task({"type": "test"})
+        # Should raise so callers can handle or surface the failure
+        with pytest.raises(ValueError, match="Test error"):
+            await backend.submit_task({"type": "test"})
 
 
 class TestDynamicTenantDiscovery: