Workspaces

from ndi_sdk import NdiClient

with NdiClient() as client:
    workspace = client.workspaces.create(name="fy25-audit")
    client.jobs.wait(
        client.files.upload(
            workspace.workspace_id,
            "report.pdf",
            path="reports/report.pdf",
        ).job_id
    )
    client.jobs.wait(
        client.ingestion.ingest(workspace.workspace_id, path_prefix="reports/").job_id,
        timeout=600,
    )
    hits = client.tools.hybrid_search(
        workspace.workspace_id,
        query="total liabilities at year end",
        k=5,
    )
    for hit in hits.hits:
        print(hit.path, hit.snippet)

def create(*, name: str, domain_slug: str = "generic", access: AccessConfig | None = None, ...) -> Workspace
def get(workspace_id) -> Workspace
def list(*, name_contains=None, cursor=None, limit=None) -> Page[Workspace]
def iter_all(*, name_contains=None) -> Iterator[Workspace]
def stats(workspace_id) -> WorkspaceStats
def delete(workspace_id, *, confirm_name: str) -> Job

client.files.upload(workspace_id, content, *, path: str, ...)
client.files.upload_chunked(...)
client.files.create_upload_grant(workspace_id, *, path=None, max_bytes=None, ...)
client.ingestion.ingest(workspace_id, *, file_ids=None, path_prefix=None, stale_only=False, ...)
client.ingestion.reconcile(workspace_id, *, auto_ingest=False, ...)
client.ingestion.build_knowledge_graph(workspace_id)

client.tools.hybrid_search(workspace_id, *, query: str, k: int = 10, path_prefix=None)
client.tools.qa_file(workspace_id, *, path: str, query: str)
client.tools.query_tables(workspace_id, *, paths: list[str], query: str)
client.tools.run_sql(workspace_id, *, sql: str)          # Python only
client.search.fact(workspace_id, *, query: str, ...)
client.search.deep(workspace_id, *, query: str, session_id=None, ...)
client.search.filtered(workspace_id, *, query: str, ...)  # Python only