feat(docling-serve): add DoclingServeConverter integration

Adds a new DoclingServeConverter component that converts documents
by sending them to a running docling-serve HTTP server. Supports
local files, URLs, and ByteStreams; markdown, text, and JSON export
formats; optional API key authentication; and both sync (run) and
async (arun) execution.

Closes #2960

Author: SyedShahmeerAli12

integrations/docling_serve/pydoc/config_docusaurus.yml

@@ -0,0 +1,13 @@
+loaders:
+  - modules:
+      - haystack_integrations.components.converters.docling_serve.converter
+    search_path: [../src]
+processors:
+  - type: filter
+    documented_only: true
+    skip_empty_modules: true
+renderer:
+  description: DoclingServe integration for Haystack
+  id: integrations-docling-serve
+  filename: docling_serve.md
+  title: DoclingServe

integrations/docling_serve/src/haystack_integrations/components/converters/docling_serve/converter.py

@@ -34,8 +34,9 @@ class ExportType(str, Enum):
 @component
 class DoclingServeConverter:
     """
-    Converts documents to Haystack Documents using a [DoclingServe](https://github.com/docling-project/docling-serve)
-    server.
+    Converts documents to Haystack Documents using a DoclingServe server.
+
+    See [DoclingServe](https://github.com/docling-project/docling-serve).
 
     DoclingServe hosts Docling in a scalable HTTP server, supporting PDFs, Office documents, HTML, and many other
     formats. Unlike the local `DoclingConverter`, this component has no heavy ML dependencies — all processing

integrations/docling_serve/src/haystack_integrations/components/converters/py.typed

@@ -4,11 +4,9 @@
 
 import json
 import logging
-from pathlib import Path
 from unittest.mock import AsyncMock, MagicMock, patch
 
 import pytest
-from haystack import Document
 from haystack.dataclasses import ByteStream
 from haystack.utils import Secret
 
@@ -82,10 +80,12 @@ def test_from_dict(self):
         assert converter.export_type == ExportType.JSON
         assert converter.timeout == 60.0
 
-    def test_to_dict_with_api_key(self):
-        converter = DoclingServeConverter(api_key=Secret.from_token("test-key"))
+    def test_to_dict_with_api_key(self, monkeypatch):
+        monkeypatch.setenv("DOCLING_API_KEY", "test-key")
+        converter = DoclingServeConverter(api_key=Secret.from_env_var("DOCLING_API_KEY"))
         data = converter.to_dict()
         assert data["init_parameters"]["api_key"] is not None
+        assert data["init_parameters"]["api_key"]["type"] == "env_var"
 
     def test_roundtrip(self):
         converter = DoclingServeConverter(
@@ -207,7 +207,7 @@ def test_run_with_meta(self):
     def test_run_bytestream_meta_merged(self):
         converter = DoclingServeConverter()
         mock_resp = _mock_response("text")
-        bs = ByteStream(data=b"bytes", meta={"file_path": "/tmp/doc.pdf"})
+        bs = ByteStream(data=b"bytes", meta={"file_path": "doc.pdf"})
 
         with patch("httpx.Client") as mock_client_cls:
             mock_client = MagicMock()
@@ -219,7 +219,7 @@ def test_run_bytestream_meta_merged(self):
             result = converter.run(sources=[bs], meta={"page": 1})
 
         doc = result["documents"][0]
-        assert doc.meta["file_path"] == "/tmp/doc.pdf"
+        assert doc.meta["file_path"] == "doc.pdf"
         assert doc.meta["page"] == 1
 
     def test_run_skips_on_http_error(self, caplog):