Functions — github.com/Harmeet10000/AgentNexus-LangChain-FastAPI

hub / github.com/Harmeet10000/AgentNexus-LangChain-FastAPI / functions

Functions1,424 in github.com/Harmeet10000/AgentNexus-LangChain-FastAPI

⨍ Functions 1,424◇ Types & classes 479↳ Endpoints 62

↓ 1 callersFunction_looks_like_policy

(text: str)

src/app/features/documents/classification.py:186

↓ 1 callersFunction_make_ingest_document_node

( *, object_store: StorageService, repo: DocumentRepository, graphiti: Graphiti | None, in

src/app/features/documents/ingestion_graph.py:66

↓ 1 callersMethod_map_event_to_frame

( self, event: object, current_step: int, )

src/app/features/agent_saul/service.py:195

↓ 1 callersMethod_mark_failed

( self, event_id: str, error: str, session: AsyncSession, )

src/app/shared/outbox/relay.py:137

↓ 1 callersMethod_mark_published

( self, event_id: str, session: AsyncSession, )

src/app/shared/outbox/relay.py:126

↓ 1 callersFunction_markdown_to_csv

Convert markdown table to CSV.

src/app/shared/rag/document_processing/docling_enhanced.py:266

↓ 1 callersFunction_markdown_to_html

Convert markdown table to HTML.

src/app/shared/rag/document_processing/docling_enhanced.py:287

↓ 1 callersFunction_merge_metadata

( *, extracted: LegalMetadataExtraction, classified: ClassifiedDocument, )

src/app/features/documents/legal_metadata.py:130

↓ 1 callersFunction_merge_warning_lists

(groups: list[list[QualityWarningDTO]])

src/app/features/documents/service.py:920

↓ 1 callersFunction_naturalize_tables

(markdown: str)

src/app/shared/langgraph_layer/ingestion_kb/nodes.py:844

↓ 1 callersFunction_normalize_path_otel

(path: str)

src/app/middleware/otel.py:13

↓ 1 callersFunction_normalize_plan

(plan: QueryPlan)

src/app/shared/langgraph_layer/retrieval_kb/nodes.py:316

↓ 1 callersMethod_normalize_tool_result

( self, server_name: str, tool_name: str, result: Any )

src/mcp_core/client/manager.py:237

↓ 1 callersFunction_normalized_extension

(filename: str)

src/app/shared/services/storage.py:728

↓ 1 callersFunction_parse_document_with_docling

( raw_bytes: bytes, filename: str, source: str, )

src/app/shared/langgraph_layer/ingestion_kb/nodes.py:401

↓ 1 callersFunction_parse_extraction_json

(response_text: str)

src/app/shared/crawler/processor.py:308

↓ 1 callersFunction_parse_reconciliation_decision

(result: object)

src/app/shared/langgraph_layer/reconciliation/nodes.py:369

↓ 1 callersFunction_parse_search_result

Convert the FT.SEARCH list response into a structured payload.

src/app/utils/cache/redis_func.py:1063

↓ 1 callersFunction_parse_subgraph_records

Parse raw Neo4j records into SubgraphResult. Filters nodes by MemoryScope entity type allowlist. Deduplicates edges. Args: recor

src/app/shared/rag/graphiti/subgraph.py:266

↓ 1 callersFunction_patch_loguru_sink

(logger_provider: SDKLoggerProvider)

src/app/shared/otel/logs.py:37

↓ 1 callersMethod_process_crawl_result

Process a single crawl result with optional Gemini processing.

src/app/features/crawler/service.py:147

↓ 1 callersFunction_producer

()

src/app/shared/rag/pageindex/functions.py:163

↓ 1 callersMethod_raise_if_circuit_open

(self, server_name: str)

src/mcp_core/client/manager.py:262

↓ 1 callersMethod_raise_if_rejected

( self, settings: CircuitBreakerSettings, status: AcquireStatus, )

src/app/shared/circuit_breaker/service.py:114

↓ 1 callersFunction_raise_non_iterable_stream_response

()

src/app/shared/rag/pageindex/functions.py:17

↓ 1 callersFunction_raise_rate_limit_exceeded

(retry_seconds: int)

src/app/utils/rate_limit/service.py:45

↓ 1 callersFunction_read_authorization_header_token

(connection: HTTPConnection)

src/app/features/auth/dependencies.py:63

↓ 1 callersMethod_read_correlation_id

(scope: dict)

src/app/middleware/server_middleware.py:105

↓ 1 callersMethod_read_document

Read document content from file - supports multiple formats via Docling. Returns: Tuple of (markdown_content, docling_do

src/app/shared/rag/document_processing/ingest.py:251

↓ 1 callersFunction_read_float

Read a float from a mapping.

src/app/shared/services/tavily.py:79

↓ 1 callersFunction_read_llm_content

(result: object)

src/app/shared/langgraph_layer/reconciliation/nodes.py:375

↓ 1 callersMethod_receive_json

(self, ws: WebSocket)

src/app/features/agent_saul/service.py:367

↓ 1 callersFunction_recency_score

Calculate recency score based on episode age.

src/app/shared/rag/graphiti/client.py:559

↓ 1 callersMethod_record_failure

( self, settings: CircuitBreakerSettings, keys: CircuitBreakerKeys, )

src/app/shared/circuit_breaker/service.py:142

↓ 1 callersMethod_record_success

( self, service_name: str, keys: CircuitBreakerKeys, )

src/app/shared/circuit_breaker/service.py:127

↓ 1 callersFunction_register_tools

(server: Any)

src/mcp_core/server/tools.py:174

↓ 1 callersFunction_resolve_extraction_schema

( schema_type: SchemaType | None, custom_schema: dict[str, Any] | None, )

src/app/shared/crawler/processor.py:272

↓ 1 callersFunction_retrieve_graphiti_context

Retrieve and format Graphiti context for the current task.

src/app/shared/rag/graphiti/memory_pipeline.py:203

↓ 1 callersFunction_row_to_chunk

(row: dict[str, object])

src/app/features/documents/service.py:932

↓ 1 callersFunction_row_to_chunk

(row: dict[str, Any])

src/app/shared/langgraph_layer/retrieval_kb/nodes.py:369

↓ 1 callersFunction_run_decay_async

Recompute decay scores for memory rows using asyncpg bulk updates.

src/tasks/memory_decay_reconciliation_tasks.py:64

↓ 1 callersFunction_run_parallel_search

( repo: SearchRepository, *, query: str, query_embedding: list[float], candidate_limit: in

src/app/features/search/service.py:362

↓ 1 callersFunction_runtime_dependencies

()

src/mcp_core/server/tools.py:64

↓ 1 callersMethod_save_to_cache

Save crawl result to cache.

src/app/shared/crawler/crawler.py:93

↓ 1 callersMethod_save_to_postgres

Save document and chunks to PostgreSQL.

src/app/shared/rag/document_processing/ingest.py:406

↓ 1 callersFunction_save_to_rag_data

Save extraction results to rag_data table.

src/app/shared/rag/document_processing/todo_temp.py:265

↓ 1 callersFunction_search_index_exists

Return whether a RediSearch index already exists.

src/app/utils/cache/redis_func.py:889

↓ 1 callersFunction_search_statutes_postgres

Full-text search against the statutes table. Assumes schema: statutes ( id UUID PRIMARY KEY, title

src/app/shared/langchain_layer/agents/tools/search_legal_precedents.py:157

↓ 1 callersFunction_segment_legal_chunks

( *, parsed: ParsedDocument, classified: ClassifiedDocument, )

src/app/features/documents/classification.py:141

↓ 1 callersFunction_serialize_data

Normalize payloads for error metadata and mixed response payloads.

src/app/utils/http_response.py:11

↓ 1 callersFunction_serialize_result

(result: GraphitiSearchResult)

src/app/shared/langchain_layer/agents/tools/get_obligation_chain.py:118

↓ 1 callersMethod_set_in_postgres

( self, key: str, result_json: str, tool_name: str, user_id: str,

src/app/shared/langchain_layer/agents/tools/idempotency.py:161

↓ 1 callersFunction_setup_auto_instrumentation

()

src/app/shared/otel/instrument.py:4

↓ 1 callersFunction_setup_logger_provider

(resource: Resource)

src/app/shared/otel/logs.py:24

↓ 1 callersFunction_setup_meter_provider

( resource: Resource, export_interval_ms: int = 15000, )

src/app/shared/otel/metrics.py:11

↓ 1 callersFunction_setup_tracer_provider

(resource: Resource, sample_rate: float = 1.0)

src/app/shared/otel/tracer.py:9

↓ 1 callersFunction_store_chunks

( *, session: AsyncSession, state: IngestionState, parsed: ParsedDocument, metadata: Contr

src/app/shared/langgraph_layer/ingestion_kb/nodes.py:623

↓ 1 callersFunction_store_entities

( session: AsyncSession, state: IngestionState, )

src/app/shared/langgraph_layer/ingestion_kb/nodes.py:534

↓ 1 callersFunction_store_relationships

( session: AsyncSession, state: IngestionState, entity_id_map: dict[str, str], )

src/app/shared/langgraph_layer/ingestion_kb/nodes.py:575

↓ 1 callersFunction_stored_chunk_id

(state: IngestionState, clause_id: str)

src/app/shared/langgraph_layer/ingestion_kb/nodes.py:790

↓ 1 callersFunction_strip_markdown_fences

(content: str)

src/app/shared/langgraph_layer/reconciliation/nodes.py:380

↓ 1 callersFunction_table_to_sentences

(lines: list[str])

src/app/shared/langgraph_layer/ingestion_kb/nodes.py:867

↓ 1 callersFunction_task_relevance

Compute task relevance as query-content word overlap.

src/app/shared/rag/graphiti/client.py:580

↓ 1 callersFunction_to_ranked_rows

(rows: list[dict[str, object]])

src/app/features/documents/service.py:823

↓ 1 callersFunction_to_user_response

(user: User)

src/app/features/auth/service.py:49

↓ 1 callersMethod_transcribe_audio

Transcribe audio file using Whisper ASR via Docling.

src/app/shared/rag/document_processing/ingest.py:319

↓ 1 callersFunction_truncate_payload

(data: Any)

src/mcp_core/server/tools.py:38

↓ 1 callersFunction_trust_score

Extract trust score from metadata.

src/app/shared/rag/graphiti/client.py:567

↓ 1 callersFunction_upsert_parent_document

( session: AsyncSession, state: IngestionState, parsed: ParsedDocument, metadata: ContractMeta

src/app/shared/langgraph_layer/ingestion_kb/nodes.py:482

↓ 1 callersFunction_utc_now_iso

()

src/app/shared/langgraph_layer/agent_saul/nodes.py:142

↓ 1 callersFunction_validate_search_inputs

Validate search inputs. Args: query: The search query string max_results: Maximum number of results requested topic: Sear

src/app/shared/services/tavily.py:45

↓ 1 callersFunction_vector_literal

(embedding: list[float])

src/app/shared/langgraph_layer/ingestion_kb/nodes.py:818

↓ 1 callersFunction_vector_search_clauses

pgvector cosine similarity search on clauses table. Time filter: "recent" = last 90 days; "all" = no constraint. TODO: embed query using same

src/app/shared/langchain_layer/agents/tools/precedent_tools.py:220

↓ 1 callersFunction_verify_legal_chunks

( *, repo: DocumentRepository, graphiti: Graphiti | None, user_id: str, document_id: str,

src/app/features/documents/service.py:652

↓ 1 callersFunction_version_target_entity_id

(item: object)

src/app/shared/langgraph_layer/reconciliation/nodes.py:395

↓ 1 callersMethod_warm_redis_cache

(self, key: str, result: ToolResult)

src/app/shared/langchain_layer/agents/tools/idempotency.py:126

↓ 1 callersFunction_warnings_from_rows

(rows: list[dict[str, object]])

src/app/features/documents/service.py:928

↓ 1 callersFunction_wire_graph

(graph: Any, nodes: SaulGraphNodes)

src/app/shared/langgraph_layer/agent_saul/graph.py:30

↓ 1 callersFunction_worker

(doc_path: str)

src/app/shared/rag/pageindex/functions.py:83

↓ 1 callersFunction_write_single_clause_episode

( segment: ClauseSegment, doc_id: str, user_id: str, thread_id: str, jurisdiction: str,

src/app/shared/rag/graphiti/write_clause_episodes.py:152

↓ 1 callersFunction_write_single_relationship_edge

( relationship: LegalRelationship, doc_id: str, user_id: str, thread_id: str, graphiti_ser

src/app/shared/rag/graphiti/write_clause_episodes.py:224

↓ 1 callersMethodabatch

Batch invoke the agent concurrently on multiple messages. Each message gets its own thread_id for isolated history.

src/app/shared/langchain_layer/agents/factory.py:283

↓ 1 callersFunctionacquire_idempotency_lock

Acquire a processing lock for a business operation.

src/app/connections/celery_reliability.py:96

↓ 1 callersFunctionadd_activity

Add activity to user's activity feed.

src/app/examples/redis_examples.py:152

↓ 1 callersMethodainvoke

Run the reconciliation graph for a single user.

src/tasks/memory_decay_reconciliation_tasks.py:44

↓ 1 callersFunctionainvoke_multimodal

( text: str, *, image_path: str | Path | None = None, image_url: str | None = None, image_

src/app/shared/langchain_layer/models.py:362

↓ 1 callersFunctionainvoke_text

Single async text call, returns plain string.

src/app/shared/langchain_layer/models.py:238

↓ 1 callersMethodallows_entity_type

(self, entity_type: str)

src/app/shared/langchain_layer/agents/memory/memory_scope.py:79

↓ 1 callersMethodanalyze_chunks

(self)

src/app/features/documents/repository.py:253

↓ 1 callersMethodanalyze_chunks

(self)

src/app/features/search/repository.py:165

↓ 1 callersFunctionapage_index

Run PageIndex document indexing without blocking the event loop.

src/app/shared/rag/pageindex/functions.py:22

↓ 1 callersMethodask_legal

Run the clauses-backed retrieval graph and return a grounded answer.

src/app/features/search/service.py:250

↓ 1 callersMethodastream

Stream the agent's response token by token. stream_mode options: "messages" (tokens) | "updates" (node-level) | "values" Us

src/app/shared/langchain_layer/agents/factory.py:250

↓ 1 callersFunctionbind_mcp_parent_app

(app: FastAPI | None)

src/mcp_core/server/tools.py:30

↓ 1 callersMethodbm25_search

( self, *, user_id: str, query: str, candidate_limit: int, fil

src/app/features/documents/repository.py:305

↓ 1 callersMethodbm25_search

( self, *, query: str, candidate_limit: int, metadata_filter: dict[str

src/app/features/search/repository.py:168

↓ 1 callersFunctionbounded

(coro: Any)

src/app/shared/langchain_layer/models.py:416

↓ 1 callersMethodbuild

Assemble the full system prompt string with plain labeled sections.

src/app/shared/langchain_layer/prompts.py:102

↓ 1 callersFunctionbuildSections

(doc *model.Document)

src/lynk/internal/adapters/docx/reader.go:189

↓ 1 callersFunctionbuild_agent_registry

Instantiate all agents + LLM chains once. Called from build_saul_graph — never call this inside a node function. Model assignment:

src/app/shared/langgraph_layer/agent_saul/factory.py:101

← previous next →401–500 of 1,424, ranked by callers