Merge pull request #22 from nuhatech/dev

Release v0.1.21

Author: mazy06000

CHANGELOG.md

@@ -7,6 +7,11 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+## [0.1.21] - 2026-02-11
+
+### Fixed
+- **Deep research filter safety net**: Added fallback in `_filter_results` so that when the LLM filter returns 0 sources but search results exist, all results are kept instead of being silently discarded. This prevents deep research from returning empty answers when the filter stage produces unparseable output.
+
 ## [0.1.20] - 2025-11-15
 
 ### Added
@@ -259,7 +264,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Example scripts for common use cases
 - API reference documentation
 
-[Unreleased]: https://github.com/nuhatech/maktaba/compare/v0.1.20...HEAD
+[Unreleased]: https://github.com/nuhatech/maktaba/compare/v0.1.21...HEAD
+[0.1.21]: https://github.com/nuhatech/maktaba/compare/v0.1.20...v0.1.21
 [0.1.20]: https://github.com/nuhatech/maktaba/compare/v0.1.19...v0.1.20
 [0.1.19]: https://github.com/nuhatech/maktaba/compare/v0.1.18...v0.1.19
 [0.1.18]: https://github.com/nuhatech/maktaba/compare/v0.1.17...v0.1.18

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "maktaba"
-version = "0.1.20"
+version = "0.1.21"
 description = "Production-ready RAG infrastructure for multilingual applications"
 authors = [
     {name = "NuhaTech", email = "contact@nuhatech.com"}

src/maktaba/pipeline/deep_research/pipeline.py

@@ -267,6 +267,16 @@ async def _filter_results(
             if 1 <= index <= len(results.results):
                 filtered_views.append(results.results[index - 1])
 
+        # Safety net: if filter returned 0 but results exist, keep all results
+        if not filtered_views and results.results:
+            LOGGER.warning(
+                "deep_research.filter kept=0 but %d results available — "
+                "returning all results as fallback",
+                len(results.results),
+            )
+            filtered_views = list(results.results)
+            sources = list(range(1, len(filtered_views) + 1))
+
         LOGGER.info("deep_research.filter kept=%d", len(filtered_views))
         return FilteredResultsData(
             filtered_results=SearchResultsCollection.from_sequence(filtered_views),