Home / langchain-ai / langgraph
Repository Analysis

langchain-ai/langgraph

Build resilient agents.

34.1 Strong AI signal View on GitHub
34.1
Adjusted Score
34.1
Raw Score
100%
Time Factor
2026-05-29
Last Push
33,365
Stars
Python
Language
193,192
Lines of Code
557
Files
3937
Pattern Hits
2026-05-31
Scan Date

Score History

Severity Breakdown

CRITICAL 0HIGH 402MEDIUM 515LOW 3020

Pattern Findings

3937 matches across 18 categories. Click a row to expand file-level details.

Hyper-Verbose Identifiers2172 hits · 1821 pts
SeverityFileLineSnippet
LOW…int-postgres/langgraph/checkpoint/postgres/__init__.py444 def get_delta_channel_history(
LOW…eckpoint-postgres/langgraph/checkpoint/postgres/aio.py405 async def aget_delta_channel_history(
LOW…ckpoint-postgres/langgraph/checkpoint/postgres/base.py412 def _build_delta_channels_writes_history(
LOW…bs/checkpoint-postgres/langgraph/store/postgres/aio.py530 async def _batch_list_namespaces_ops(
LOW…s/checkpoint-postgres/langgraph/store/postgres/base.py411 def _prepare_batch_search_queries(
LOW…s/checkpoint-postgres/langgraph/store/postgres/base.py568 def _get_batch_list_namespaces_queries(
LOW…s/checkpoint-postgres/langgraph/store/postgres/base.py1073 def _batch_list_namespaces_ops(
LOWlibs/checkpoint-postgres/tests/test_sync.py285def test_pending_sends_migration(saver_name: str) -> None:
LOWlibs/checkpoint-postgres/tests/test_sync.py334def test_get_checkpoint_no_channel_values(
LOWlibs/checkpoint-postgres/tests/test_sync.py351 def patched_load_checkpoint_tuple(value):
LOWlibs/checkpoint-postgres/tests/test_async.py297async def test_pending_sends_migration(saver_name: str) -> None:
LOWlibs/checkpoint-postgres/tests/test_async.py346async def test_get_checkpoint_no_channel_values(
LOWlibs/checkpoint-postgres/tests/test_async.py364 async def patched_load_checkpoint_tuple(value):
LOWlibs/checkpoint-postgres/tests/test_async.py377async def test_delta_channel_chain_reconstruction(saver_name: str) -> None:
LOWlibs/checkpoint-postgres/tests/test_store.py220def test_batch_list_namespaces_ops(store: PostgresStore) -> None:
LOWlibs/checkpoint-postgres/tests/test_store.py454def test_vector_store_initialization(
LOWlibs/checkpoint-postgres/tests/test_store.py464def test_vector_insert_with_auto_embedding(vector_store: PostgresStore) -> None:
LOWlibs/checkpoint-postgres/tests/test_store.py486def test_vector_update_with_embedding(vector_store: PostgresStore) -> None:
LOWlibs/checkpoint-postgres/tests/test_store.py515def test_vector_search_with_filters(
LOWlibs/checkpoint-postgres/tests/test_store.py559def test_vector_search_pagination(vector_store: PostgresStore) -> None:
LOWlibs/checkpoint-postgres/tests/test_store.py578def test_vector_search_edge_cases(vector_store: PostgresStore) -> None:
LOWlibs/checkpoint-postgres/tests/test_store.py606def test_embed_with_path_sync(
LOWlibs/checkpoint-postgres/tests/test_store.py678def test_embed_with_path_operation_config(
LOWlibs/checkpoint-postgres/tests/test_async_store.py335async def test_batch_list_namespaces_ops(store: AsyncPostgresStore) -> None:
LOWlibs/checkpoint-postgres/tests/test_async_store.py379async def test_abatch_uses_single_pool_checkout(monkeypatch) -> None:
LOWlibs/checkpoint-postgres/tests/test_async_store.py474async def test_vector_store_initialization(
LOWlibs/checkpoint-postgres/tests/test_async_store.py484async def test_vector_insert_with_auto_embedding(
LOWlibs/checkpoint-postgres/tests/test_async_store.py508async def test_vector_update_with_embedding(vector_store: AsyncPostgresStore) -> None:
LOWlibs/checkpoint-postgres/tests/test_async_store.py540async def test_vector_search_with_filters(vector_store: AsyncPostgresStore) -> None:
LOWlibs/checkpoint-postgres/tests/test_async_store.py577async def test_vector_search_pagination(vector_store: AsyncPostgresStore) -> None:
LOWlibs/checkpoint-postgres/tests/test_async_store.py597async def test_vector_search_edge_cases(vector_store: AsyncPostgresStore) -> None:
LOWlibs/langgraph/langgraph/types.py107def ensure_valid_checkpointer(checkpointer: Checkpointer) -> Checkpointer:
LOWlibs/langgraph/langgraph/callbacks.py154def _configure_graph_callbacks(
LOWlibs/langgraph/langgraph/callbacks.py363def get_sync_graph_callback_manager_for_config(
LOWlibs/langgraph/langgraph/callbacks.py380def get_async_graph_callback_manager_for_config(
LOWlibs/langgraph/langgraph/pregel/_call.py113def _lookup_module_and_qualname(
LOWlibs/langgraph/langgraph/pregel/_call.py157def _explode_args_trace_inputs(
LOWlibs/langgraph/langgraph/pregel/_call.py175def get_runnable_for_entrypoint(func: Callable[..., Any]) -> Runnable:
LOWlibs/langgraph/langgraph/pregel/_algo.py770def _read_errors_from_pending_writes(
LOWlibs/langgraph/langgraph/pregel/_algo.py780def _read_error_for_task_id_from_pending_writes(
LOWlibs/langgraph/langgraph/pregel/_algo.py789def _read_error_source_node_from_pending_writes(
LOWlibs/langgraph/langgraph/pregel/_algo.py800def prepare_push_task_functional(
LOWlibs/langgraph/langgraph/pregel/_algo.py1110def prepare_node_error_handler_task(
LOWlibs/langgraph/langgraph/pregel/_algo.py1442def sanitize_untracked_values_in_send(
LOWlibs/langgraph/langgraph/pregel/_checkpoint.py37def delta_channels_to_snapshot(
LOWlibs/langgraph/langgraph/pregel/_checkpoint.py187async def achannels_from_checkpoint(
LOWlibs/langgraph/langgraph/pregel/_loop.py369 def _push_graph_lifecycle_event(
LOWlibs/langgraph/langgraph/pregel/_loop.py724 def _reapply_writes_to_succeeded_nodes(
LOWlibs/langgraph/langgraph/pregel/_loop.py739 def _resume_error_handlers_if_applicable(self) -> None:
LOWlibs/langgraph/langgraph/pregel/_loop.py1507 def _checkpointer_put_after_previous(
LOWlibs/langgraph/langgraph/pregel/_loop.py1759 async def _checkpointer_put_after_previous(
LOWlibs/langgraph/langgraph/pregel/debug.py74def is_multiple_channel_write(value: Any) -> bool:
LOWlibs/langgraph/langgraph/pregel/main.py415def _normalize_stream_transformer_factories(
LOWlibs/langgraph/langgraph/pregel/main.py836 def _apply_checkpointer_allowlist(
LOWlibs/langgraph/langgraph/pregel/main.py2857 def emit_graph_lifecycle_events(loop: SyncPregelLoop) -> None:
LOWlibs/langgraph/langgraph/pregel/main.py3298 async def aemit_graph_lifecycle_events(loop: AsyncPregelLoop) -> None:
LOWlibs/langgraph/langgraph/pregel/main.py4213def _coerce_checkpoint_values(payload: Any, mapper: Callable[[Any], Any]) -> None:
LOWlibs/langgraph/langgraph/pregel/_runner.py171 def _should_route_to_error_handler(self, task: PregelExecutableTask) -> bool:
LOWlibs/langgraph/langgraph/pregel/_retry.py315def _is_user_raised_cancelled() -> bool:
LOWlibs/langgraph/langgraph/pregel/_retry.py544def _checkpoint_ns_for_parent_command(ns: str) -> str:
2112 more matches not shown…
Cross-Language Confusion247 hits · 1422 pts
SeverityFileLineSnippet
HIGH…ckpoint-postgres/langgraph/checkpoint/postgres/base.py77 "ALTER TABLE checkpoint_blobs ALTER COLUMN blob DROP not null;",
HIGHlibs/langgraph/langgraph/pregel/_loop.py1674 self.stack.push(self._suppress_interrupt)
HIGHlibs/langgraph/langgraph/pregel/_loop.py1933 self.stack.push(self._suppress_interrupt)
HIGHlibs/langgraph/langgraph/stream/transformers.py81 self._log.push(params["data"])
HIGHlibs/langgraph/langgraph/stream/transformers.py116 self._log.push(params["data"])
HIGHlibs/langgraph/langgraph/stream/transformers.py151 self._log.push(params["data"])
HIGHlibs/langgraph/langgraph/stream/transformers.py313 self._log.push(stream)
HIGHlibs/langgraph/langgraph/stream/transformers.py328 self._log.push(stream)
HIGHlibs/langgraph/langgraph/stream/transformers.py648 self._channel.push(payload)
HIGHlibs/langgraph/langgraph/stream/transformers.py659 self._channel.push(payload)
HIGHlibs/langgraph/langgraph/stream/transformers.py731 self._log.push(handle)
HIGHlibs/langgraph/langgraph/stream/transformers.py815 handle._mux.push(event)
HIGHlibs/langgraph/langgraph/stream/transformers.py957 self._log.push(params["data"])
HIGHlibs/langgraph/langgraph/stream/transformers.py993 self._log.push(params["data"])
HIGHlibs/langgraph/langgraph/stream/transformers.py1033 self._log.push(params["data"])
HIGHlibs/langgraph/langgraph/stream/run_stream.py121 self._mux.push(event)
HIGHlibs/langgraph/langgraph/stream/_mux.py296 self._events.push(event)
HIGHlibs/langgraph/langgraph/stream/_mux.py378 self._events.push(event)
HIGHlibs/langgraph/langgraph/stream/_mux.py523 self._events.push(event)
HIGH…bs/langgraph/tests/test_stream_subgraph_transformer.py193 mux.push(_tasks_start(["agent:abc"], task_id="t1", name="tool"))
HIGH…bs/langgraph/tests/test_stream_subgraph_transformer.py205 mux.push(_tasks_start(["agent:abc"], task_id="t1", name="tool"))
HIGH…bs/langgraph/tests/test_stream_subgraph_transformer.py206 mux.push(_tasks_result([], task_id="abc", name="agent"))
HIGH…bs/langgraph/tests/test_stream_subgraph_transformer.py215 mux.push(_tasks_start(["agent:abc"], task_id="t1", name="tool"))
HIGH…bs/langgraph/tests/test_stream_subgraph_transformer.py216 mux.push(_tasks_result([], task_id="abc", name="agent", error="boom"))
HIGH…bs/langgraph/tests/test_stream_subgraph_transformer.py225 mux.push(_tasks_start(["agent:abc"], task_id="t1", name="tool"))
HIGH…bs/langgraph/tests/test_stream_subgraph_transformer.py226 mux.push(
HIGH…bs/langgraph/tests/test_stream_subgraph_transformer.py243 mux.push(_tasks_start(["agent:abc"], task_id="t1", name="tool"))
HIGH…bs/langgraph/tests/test_stream_subgraph_transformer.py250 mux.push(_tasks_start(["agent:abc", "tool:def"], task_id="t2", name="deep"))
HIGH…bs/langgraph/tests/test_stream_subgraph_transformer.py262 mux.push(_tasks_start(["agent:abc"], task_id="t1", name="tool"))
HIGH…bs/langgraph/tests/test_stream_subgraph_transformer.py271 mux.push(_tasks_start(["agent:abc"], task_id="t1", name="tool"))
HIGH…bs/langgraph/tests/test_stream_subgraph_transformer.py280 mux.push(_tasks_start(["agent:abc"], task_id="t1", name="tool"))
HIGH…bs/langgraph/tests/test_stream_subgraph_transformer.py299 mux.push(_tasks_start(["agent:abc"], task_id="t1", name="tool"))
HIGH…bs/langgraph/tests/test_stream_subgraph_transformer.py300 mux.push(_tasks_result([], task_id="abc", name="agent", error="boom"))
HIGH…bs/langgraph/tests/test_stream_subgraph_transformer.py316 mux.push(_tasks_start(["agent:abc"], task_id="t1", name="tool"))
HIGH…bs/langgraph/tests/test_stream_subgraph_transformer.py317 mux.push(_tasks_result([], task_id="abc", name="agent"))
HIGH…bs/langgraph/tests/test_stream_subgraph_transformer.py357 mux.push(_tasks_start(["agent:abc"], task_id="t1", name="tool"))
HIGH…bs/langgraph/tests/test_stream_subgraph_transformer.py368 mux.push(event)
HIGH…bs/langgraph/tests/test_stream_subgraph_transformer.py134 Mini-muxes are created during `mux.push(...)` when a new direct
HIGHlibs/langgraph/tests/test_stream_data_transformers.py99 mux.push(_custom_event([], {"status": "processing"}))
HIGHlibs/langgraph/tests/test_stream_data_transformers.py100 mux.push(_custom_event([], {"status": "done"}))
HIGHlibs/langgraph/tests/test_stream_data_transformers.py111 mux.push(_custom_event(["subgraph:abc"], {"from": "child"}))
HIGHlibs/langgraph/tests/test_stream_data_transformers.py121 mux.push(_custom_event([], {"from": "root"}))
HIGHlibs/langgraph/tests/test_stream_data_transformers.py122 mux.push(_custom_event(["agent:abc"], {"from": "self"}))
HIGHlibs/langgraph/tests/test_stream_data_transformers.py123 mux.push(_custom_event(["agent:abc", "deep:def"], {"from": "child"}))
HIGHlibs/langgraph/tests/test_stream_data_transformers.py134 mux.push(_custom_event([], "string_payload"))
HIGHlibs/langgraph/tests/test_stream_data_transformers.py135 mux.push(_custom_event([], 42))
HIGHlibs/langgraph/tests/test_stream_data_transformers.py136 mux.push(_custom_event([], [1, 2, 3]))
HIGHlibs/langgraph/tests/test_stream_data_transformers.py146 mux.push(_custom_event([], "data"))
HIGHlibs/langgraph/tests/test_stream_data_transformers.py157 mux.push(
HIGHlibs/langgraph/tests/test_stream_data_transformers.py193 mux.push(_checkpoints_event([], checkpoint_data))
HIGHlibs/langgraph/tests/test_stream_data_transformers.py204 mux.push(_checkpoints_event(["child:abc"], {"values": {"x": 1}}))
HIGHlibs/langgraph/tests/test_stream_data_transformers.py214 mux.push(_checkpoints_event([], {"from": "root"}))
HIGHlibs/langgraph/tests/test_stream_data_transformers.py215 mux.push(_checkpoints_event(["sub:abc"], {"from": "self"}))
HIGHlibs/langgraph/tests/test_stream_data_transformers.py225 mux.push(_checkpoints_event([], {"values": {}}))
HIGHlibs/langgraph/tests/test_stream_data_transformers.py255 mux.push(_debug_event([], debug_data))
HIGHlibs/langgraph/tests/test_stream_data_transformers.py266 mux.push(_debug_event(["child:abc"], {"step": 0, "type": "task"}))
HIGHlibs/langgraph/tests/test_stream_data_transformers.py276 mux.push(_debug_event([], {"step": 0, "type": "checkpoint", "payload": {}}))
HIGHlibs/langgraph/tests/test_stream_data_transformers.py277 mux.push(_debug_event([], {"step": 1, "type": "task", "payload": {}}))
HIGHlibs/langgraph/tests/test_stream_data_transformers.py278 mux.push(_debug_event([], {"step": 1, "type": "task_result", "payload": {}}))
HIGHlibs/langgraph/tests/test_stream_data_transformers.py290 mux.push(_debug_event([], {"step": 0}))
187 more matches not shown…
Decorative Section Separators397 hits · 1384 pts
SeverityFileLineSnippet
MEDIUMlibs/langgraph/langgraph/pregel/_tools.py224 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/pregel/_tools.py226 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/stream/_types.py229 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/stream/_types.py231 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/stream/_mux.py158 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/stream/_mux.py160 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/stream/_mux.py347 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/stream/_mux.py349 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/stream/_mux.py460 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/stream/_mux.py462 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/stream/stream_channel.py85 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/stream/stream_channel.py87 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/stream/stream_channel.py108 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/stream/stream_channel.py110 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/stream/stream_channel.py116 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/stream/stream_channel.py118 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/stream/stream_channel.py155 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/stream/stream_channel.py157 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/stream/stream_channel.py198 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/stream/stream_channel.py200 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/stream/stream_channel.py241 # ------------------------------------------------------------------
MEDIUMlibs/langgraph/langgraph/stream/stream_channel.py243 # ------------------------------------------------------------------
MEDIUM…bs/langgraph/tests/test_stream_subgraph_transformer.py186# ---------------------------------------------------------------------------
MEDIUM…bs/langgraph/tests/test_stream_subgraph_transformer.py188# ---------------------------------------------------------------------------
MEDIUM…bs/langgraph/tests/test_stream_subgraph_transformer.py43# ---------------------------------------------------------------------------
MEDIUM…bs/langgraph/tests/test_stream_subgraph_transformer.py45# ---------------------------------------------------------------------------
MEDIUM…bs/langgraph/tests/test_stream_subgraph_transformer.py681# ---------------------------------------------------------------------------
MEDIUM…bs/langgraph/tests/test_stream_subgraph_transformer.py683# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_retry.py1802# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_retry.py1809# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_retry.py2304# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_retry.py2306# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_time_travel_async.py73# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_time_travel_async.py75# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_time_travel_async.py234# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_time_travel_async.py236# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_time_travel_async.py459# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_time_travel_async.py461# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_time_travel_async.py591# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_time_travel_async.py593# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_time_travel_async.py722# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_time_travel_async.py724# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_time_travel_async.py1993# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_time_travel_async.py1995# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_time_travel_async.py2135# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_time_travel_async.py2137# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_time_travel_async.py2227# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_time_travel_async.py2229# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_time_travel_async.py2398# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_time_travel_async.py2400# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_stream_data_transformers.py89# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_stream_data_transformers.py91# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_stream_data_transformers.py182# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_stream_data_transformers.py184# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_stream_data_transformers.py239# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_stream_data_transformers.py241# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_stream_data_transformers.py304# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_stream_data_transformers.py306# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_stream_data_transformers.py380# ---------------------------------------------------------------------------
MEDIUMlibs/langgraph/tests/test_stream_data_transformers.py382# ---------------------------------------------------------------------------
337 more matches not shown…
Cross-File Repetition117 hits · 585 pts
SeverityFileLineSnippet
HIGH…oint-postgres/langgraph/checkpoint/postgres/shallow.py0set up the checkpoint database asynchronously. this method creates the necessary tables in the postgres database if they
HIGH…oint-postgres/langgraph/checkpoint/postgres/shallow.py0set up the checkpoint database asynchronously. this method creates the necessary tables in the postgres database if they
HIGH…int-postgres/langgraph/checkpoint/postgres/__init__.py0set up the checkpoint database asynchronously. this method creates the necessary tables in the postgres database if they
HIGH…eckpoint-postgres/langgraph/checkpoint/postgres/aio.py0set up the checkpoint database asynchronously. this method creates the necessary tables in the postgres database if they
HIGH…int-postgres/langgraph/checkpoint/postgres/__init__.py0delete all checkpoints and writes associated with a thread id. args: thread_id: the thread id to delete. returns: none
HIGH…eckpoint-postgres/langgraph/checkpoint/postgres/aio.py0delete all checkpoints and writes associated with a thread id. args: thread_id: the thread id to delete. returns: none
HIGH…eckpoint-postgres/langgraph/checkpoint/postgres/aio.py0delete all checkpoints and writes associated with a thread id. args: thread_id: the thread id to delete. returns: none
HIGHlibs/checkpoint/langgraph/checkpoint/memory/__init__.py0delete all checkpoints and writes associated with a thread id. args: thread_id: the thread id to delete. returns: none
HIGHlibs/checkpoint/langgraph/checkpoint/memory/__init__.py0delete all checkpoints and writes associated with a thread id. args: thread_id: the thread id to delete. returns: none
HIGH…ckpoint-sqlite/langgraph/checkpoint/sqlite/__init__.py0delete all checkpoints and writes associated with a thread id. args: thread_id: the thread id to delete. returns: none
HIGH…s/checkpoint-sqlite/langgraph/checkpoint/sqlite/aio.py0delete all checkpoints and writes associated with a thread id. args: thread_id: the thread id to delete. returns: none
HIGH…s/checkpoint-sqlite/langgraph/checkpoint/sqlite/aio.py0delete all checkpoints and writes associated with a thread id. args: thread_id: the thread id to delete. returns: none
HIGH…bs/checkpoint-postgres/langgraph/store/postgres/aio.py0delete expired store items based on ttl. returns: int: the number of deleted items.
HIGH…s/checkpoint-postgres/langgraph/store/postgres/base.py0delete expired store items based on ttl. returns: int: the number of deleted items.
HIGHlibs/checkpoint-sqlite/langgraph/store/sqlite/aio.py0delete expired store items based on ttl. returns: int: the number of deleted items.
HIGHlibs/checkpoint-sqlite/langgraph/store/sqlite/base.py0delete expired store items based on ttl. returns: int: the number of deleted items.
HIGHlibs/checkpoint-postgres/tests/test_store.py0test that updating items properly updates their embeddings.
HIGHlibs/checkpoint-postgres/tests/test_async_store.py0test that updating items properly updates their embeddings.
HIGHlibs/checkpoint/tests/test_store.py0test that updating items properly updates their embeddings.
HIGHlibs/checkpoint-sqlite/tests/test_store.py0test that updating items properly updates their embeddings.
HIGHlibs/checkpoint-sqlite/tests/test_async_store.py0test that updating items properly updates their embeddings.
HIGHlibs/checkpoint-postgres/tests/test_store.py0test operation-level field configuration for vector search.
HIGHlibs/checkpoint-postgres/tests/test_store.py0test operation-level field configuration for vector search.
HIGHlibs/checkpoint-postgres/tests/test_async_store.py0test operation-level field configuration for vector search.
HIGHlibs/checkpoint-sqlite/tests/test_store.py0test operation-level field configuration for vector search.
HIGHlibs/checkpoint-sqlite/tests/test_store.py0test operation-level field configuration for vector search.
HIGHlibs/checkpoint-postgres/tests/test_store.py0compute cosine similarity between a vector x and a matrix y. lazy import numpy for efficiency.
HIGHlibs/checkpoint/langgraph/store/memory/__init__.py0compute cosine similarity between a vector x and a matrix y. lazy import numpy for efficiency.
HIGHlibs/checkpoint-sqlite/tests/test_store.py0compute cosine similarity between a vector x and a matrix y. lazy import numpy for efficiency.
HIGHlibs/checkpoint-postgres/tests/embed_test_utils.py0simple character-frequency based embeddings using random projections.
HIGHlibs/checkpoint/tests/embed_test_utils.py0simple character-frequency based embeddings using random projections.
HIGHlibs/checkpoint-sqlite/tests/test_store.py0simple character-frequency based embeddings using random projections.
HIGHlibs/checkpoint-postgres/tests/embed_test_utils.py0initialize with embedding dimensions and random seed.
HIGHlibs/checkpoint/tests/embed_test_utils.py0initialize with embedding dimensions and random seed.
HIGHlibs/checkpoint-sqlite/tests/test_store.py0initialize with embedding dimensions and random seed.
HIGHlibs/langgraph/langgraph/pregel/_loop.py0put writes for a task, to be read by the next tick.
HIGHlibs/langgraph/langgraph/pregel/_loop.py0put writes for a task, to be read by the next tick.
HIGHlibs/langgraph/langgraph/pregel/_loop.py0put writes for a task, to be read by the next tick.
HIGHlibs/langgraph/bench/wide_dict.py0the external events that are converted by the graph.
HIGHlibs/langgraph/bench/pydantic_state.py0the external events that are converted by the graph.
HIGHlibs/langgraph/bench/wide_state.py0the external events that are converted by the graph.
HIGHlibs/langgraph/bench/wide_dict.py0sops fetched from the rulebook that are relevant to the current conversation.
HIGHlibs/langgraph/bench/pydantic_state.py0sops fetched from the rulebook that are relevant to the current conversation.
HIGHlibs/langgraph/bench/wide_state.py0sops fetched from the rulebook that are relevant to the current conversation.
HIGHlibs/langgraph/bench/wide_dict.py0memory docs fetched from the memory service that are relevant to the current conversation.
HIGHlibs/langgraph/bench/pydantic_state.py0memory docs fetched from the memory service that are relevant to the current conversation.
HIGHlibs/langgraph/bench/wide_state.py0memory docs fetched from the memory service that are relevant to the current conversation.
HIGHlibs/langgraph/bench/wide_dict.py0the issue categorizations auto-generated by the ai.
HIGHlibs/langgraph/bench/pydantic_state.py0the issue categorizations auto-generated by the ai.
HIGHlibs/langgraph/bench/wide_state.py0the issue categorizations auto-generated by the ai.
HIGHlibs/langgraph/bench/wide_dict.py0the crm information for organization the current user is from.
HIGHlibs/langgraph/bench/pydantic_state.py0the crm information for organization the current user is from.
HIGHlibs/langgraph/bench/wide_state.py0the crm information for organization the current user is from.
HIGH…bs/langgraph/tests/test_stream_subgraph_transformer.py0strip push stamps from a streamchannel's internal buffer.
HIGHlibs/langgraph/tests/test_stream_data_transformers.py0strip push stamps from a streamchannel's internal buffer.
HIGH…bs/langgraph/tests/test_stream_messages_transformer.py0strip push stamps from a streamchannel's internal buffer.
HIGH…s/langgraph/tests/test_stream_lifecycle_transformer.py0strip push stamps from a streamchannel's internal buffer.
HIGHlibs/prebuilt/tests/test_tool_call_transformer.py0strip push stamps from a streamchannel's internal buffer.
HIGHlibs/checkpoint/langgraph/cache/memory/__init__.py0asynchronously get the cached values for the given keys.
HIGHlibs/checkpoint/langgraph/cache/redis/__init__.py0asynchronously get the cached values for the given keys.
57 more matches not shown…
Unused Imports400 hits · 386 pts
SeverityFileLineSnippet
LOWdocs/generate_redirects.py16
LOW…int-postgres/langgraph/checkpoint/postgres/__init__.py1
LOW…int-postgres/langgraph/checkpoint/postgres/__init__.py28
LOW…int-postgres/langgraph/checkpoint/postgres/__init__.py35
LOW…eckpoint-postgres/langgraph/checkpoint/postgres/aio.py1
LOW…eckpoint-postgres/langgraph/checkpoint/postgres/aio.py28
LOW…eckpoint-postgres/langgraph/checkpoint/postgres/aio.py35
LOW…ckpoint-postgres/langgraph/checkpoint/postgres/base.py1
LOW…eckpoint-postgres/langgraph/store/postgres/__init__.py1
LOW…eckpoint-postgres/langgraph/store/postgres/__init__.py2
LOW…eckpoint-postgres/langgraph/store/postgres/__init__.py2
LOW…bs/checkpoint-postgres/langgraph/store/postgres/aio.py1
LOW…s/checkpoint-postgres/langgraph/store/postgres/base.py1
LOWlibs/checkpoint-postgres/tests/test_store.py2
LOWlibs/checkpoint-postgres/tests/test_async_store.py2
LOWlibs/langgraph/langgraph/warnings.py3
LOWlibs/langgraph/langgraph/constants.py5
LOWlibs/langgraph/langgraph/constants.py5
LOWlibs/langgraph/langgraph/constants.py5
LOWlibs/langgraph/langgraph/types.py1
LOWlibs/langgraph/langgraph/runtime.py1
LOWlibs/langgraph/langgraph/callbacks.py7
LOWlibs/langgraph/langgraph/errors.py1
LOWlibs/langgraph/langgraph/errors.py10
LOWlibs/langgraph/langgraph/typing.py1
LOWlibs/langgraph/langgraph/pregel/_draw.py1
LOWlibs/langgraph/langgraph/pregel/_read.py1
LOWlibs/langgraph/langgraph/pregel/_call.py3
LOWlibs/langgraph/langgraph/pregel/_remote_run_stream.py2
LOWlibs/langgraph/langgraph/pregel/_tools.py1
LOWlibs/langgraph/langgraph/pregel/_algo.py1
LOWlibs/langgraph/langgraph/pregel/_io.py1
LOWlibs/langgraph/langgraph/pregel/remote.py1
LOWlibs/langgraph/langgraph/pregel/_checkpoint.py1
LOWlibs/langgraph/langgraph/pregel/protocol.py1
LOWlibs/langgraph/langgraph/pregel/_loop.py1
LOWlibs/langgraph/langgraph/pregel/_write.py1
LOWlibs/langgraph/langgraph/pregel/__init__.py1
LOWlibs/langgraph/langgraph/pregel/__init__.py1
LOWlibs/langgraph/langgraph/pregel/types.py3
LOWlibs/langgraph/langgraph/pregel/types.py3
LOWlibs/langgraph/langgraph/pregel/types.py3
LOWlibs/langgraph/langgraph/pregel/types.py3
LOWlibs/langgraph/langgraph/pregel/types.py3
LOWlibs/langgraph/langgraph/pregel/types.py3
LOWlibs/langgraph/langgraph/pregel/types.py3
LOWlibs/langgraph/langgraph/pregel/types.py3
LOWlibs/langgraph/langgraph/pregel/types.py3
LOWlibs/langgraph/langgraph/pregel/types.py3
LOWlibs/langgraph/langgraph/pregel/_messages.py1
LOWlibs/langgraph/langgraph/pregel/debug.py1
LOWlibs/langgraph/langgraph/pregel/_validate.py1
LOWlibs/langgraph/langgraph/pregel/_executor.py1
LOWlibs/langgraph/langgraph/pregel/main.py1
LOWlibs/langgraph/langgraph/pregel/_runner.py1
LOWlibs/langgraph/langgraph/pregel/_retry.py1
LOWlibs/langgraph/langgraph/pregel/_utils.py1
LOWlibs/langgraph/langgraph/_internal/_cache.py1
LOWlibs/langgraph/langgraph/_internal/_typing.py3
LOWlibs/langgraph/langgraph/_internal/_serde.py1
340 more matches not shown…
Self-Referential Comments88 hits · 304 pts
SeverityFileLineSnippet
MEDIUMlibs/langgraph/tests/test_retry.py177 # Create a RetryPolicy with default_retry_on
MEDIUMlibs/langgraph/tests/test_retry.py271 # Create a retry policy with specific parameters
MEDIUMlibs/langgraph/tests/test_retry.py346 # Create a retry policy with jitter enabled
MEDIUMlibs/langgraph/tests/test_retry.py455 # Create a retry policy with limited attempts
MEDIUMlibs/langgraph/tests/test_remote_graph.py1188 # Create a test instance
MEDIUMlibs/langgraph/tests/test_pregel_async.py9465 # Create a fake chat model that returns a simple response
MEDIUMlibs/langgraph/tests/test_pregel_async.py9468 # Create a subgraph that uses the fake chat model
MEDIUMlibs/langgraph/tests/test_pregel_async.py3850 # Define a new graph
MEDIUMlibs/langgraph/tests/test_pregel_async.py7016 # Define the subgraphs
MEDIUMlibs/langgraph/tests/test_pregel_async.py7141 # Define the subgraphs
MEDIUMlibs/langgraph/tests/test_pregel_async.py9180 # Define the graph with a sequence of nodes
MEDIUMlibs/langgraph/tests/test_large_cases.py2444 # Define the function that determines whether to continue or not
MEDIUMlibs/langgraph/tests/test_large_cases.py2454 # Define a new graph
MEDIUMlibs/langgraph/tests/test_large_cases.py2457 # Define the two nodes we will cycle between
MEDIUMlibs/langgraph/tests/test_large_cases.py556 # Define a new graph
MEDIUMlibs/langgraph/tests/test_large_cases.py1708 # Define a new graph
MEDIUMlibs/langgraph/tests/test_large_cases.py1711 # Define the two nodes we will cycle between
MEDIUMlibs/langgraph/tests/test_large_cases.py3167 # Define the function that determines whether to continue or not
MEDIUMlibs/langgraph/tests/test_large_cases.py3180 # Define a new graph
MEDIUMlibs/langgraph/tests/test_large_cases.py3183 # Define the two nodes we will cycle between
MEDIUMlibs/langgraph/tests/test_large_cases.py3828 # Define a new graph
MEDIUMlibs/langgraph/tests/test_large_cases_async.py545 # Define a new graph
MEDIUMlibs/langgraph/tests/test_large_cases_async.py1429 # Define a new graph
MEDIUMlibs/langgraph/tests/test_large_cases_async.py1432 # Define the two nodes we will cycle between
MEDIUMlibs/langgraph/tests/test_large_cases_async.py2116 # Define the function that determines whether to continue or not
MEDIUMlibs/langgraph/tests/test_large_cases_async.py2126 # Define a new graph
MEDIUMlibs/langgraph/tests/test_large_cases_async.py2129 # Define the two nodes we will cycle between
MEDIUMlibs/langgraph/tests/test_pregel.py8836 # Create a fake chat model that returns a simple response
MEDIUMlibs/langgraph/tests/test_pregel.py8839 # Create a subgraph that uses the fake chat model
MEDIUMlibs/langgraph/tests/test_pregel.py1844 # Define a new graph
MEDIUMlibs/langgraph/tests/test_pregel.py1910 # Define a new graph
MEDIUMlibs/langgraph/tests/test_pregel.py6457 # Define the subgraphs
MEDIUMlibs/langgraph/tests/test_pregel.py6576 # Define the subgraphs
MEDIUMlibs/langgraph/tests/test_pregel.py8553 # Define the graph with a sequence of nodes
MEDIUMlibs/checkpoint/tests/test_redis_cache.py307 # Create a large data structure
MEDIUMlibs/sdk-py/langgraph_sdk/_async/stream.py1257 # Create the run-done future here (async context guarantees a running loop).
MEDIUMlibs/prebuilt/langgraph/prebuilt/tool_validator.py1"""This module provides a ValidationNode class that can be used to validate tool calls
MEDIUMlibs/prebuilt/langgraph/prebuilt/chat_agent_executor.py660 # Define the function that calls the model
MEDIUMlibs/prebuilt/langgraph/prebuilt/chat_agent_executor.py788 # Define a new graph
MEDIUMlibs/prebuilt/langgraph/prebuilt/chat_agent_executor.py830 # Define the function that determines whether to continue or not
MEDIUMlibs/prebuilt/langgraph/prebuilt/chat_agent_executor.py861 # Define a new graph
MEDIUMlibs/prebuilt/langgraph/prebuilt/chat_agent_executor.py866 # Define the two nodes we will cycle between
MEDIUMlibs/prebuilt/langgraph/prebuilt/tool_node.py549 # Create a copy of the error dict to avoid mutating the original
MEDIUMlibs/prebuilt/langgraph/prebuilt/tool_node.py1034 # Create the tool request with state and runtime
MEDIUMlibs/prebuilt/langgraph/prebuilt/tool_node.py1181 # Create the tool request with state and runtime
MEDIUMlibs/prebuilt/tests/test_react_agent.py1104 # Define the subgraphs
MEDIUMlibs/prebuilt/tests/test_react_agent.py1245 # Create a React agent
MEDIUMlibs/prebuilt/tests/test_react_agent.py1260 # Create a subgraph that uses the React agent as a node
MEDIUMlibs/prebuilt/tests/test_react_agent.py1276 # Create the main workflow with the React agent as a subgraph node
MEDIUMlibs/prebuilt/tests/test_react_agent.py1336 # Create a React agent
MEDIUMlibs/prebuilt/tests/test_react_agent.py1351 # Create a subgraph that uses the React agent as a node
MEDIUMlibs/prebuilt/tests/test_react_agent.py1369 # Create the main workflow with the React agent as a subgraph node
MEDIUMlibs/prebuilt/tests/test_tool_node.py1628 # Create a mock ToolCall
MEDIUMlibs/prebuilt/tests/test_tool_node.py1631 # Create a ToolCallRequest
MEDIUMlibs/prebuilt/tests/test_tool_node.py1883 # Create a mock runtime with context
MEDIUMlibs/cli/langgraph_cli/docker.py218 # Define the Redis service first as per the test order
MEDIUMlibs/cli/tests/unit_tests/test_config.py2451 # Create a properly indented version of FORMATTED_CLEANUP_LINES for compose files
MEDIUMlibs/cli/tests/unit_tests/cli/test_templates.py28 # Create a mock response that behaves like a context manager
MEDIUMlibs/cli/tests/unit_tests/cli/test_cli.py32 # Create a temporary directory
MEDIUMlibs/cli/tests/unit_tests/cli/test_cli.py35 # Define the path for the config.json file
28 more matches not shown…
Deep Nesting252 hits · 224 pts
SeverityFileLineSnippet
LOW…oint-postgres/langgraph/checkpoint/postgres/shallow.py487
LOW…int-postgres/langgraph/checkpoint/postgres/__init__.py112
LOW…int-postgres/langgraph/checkpoint/postgres/__init__.py192
LOW…int-postgres/langgraph/checkpoint/postgres/__init__.py405
LOW…bs/checkpoint-postgres/langgraph/store/postgres/aio.py227
LOW…bs/checkpoint-postgres/langgraph/store/postgres/aio.py501
LOW…s/checkpoint-postgres/langgraph/store/postgres/base.py297
LOW…s/checkpoint-postgres/langgraph/store/postgres/base.py411
LOW…s/checkpoint-postgres/langgraph/store/postgres/base.py568
LOW…s/checkpoint-postgres/langgraph/store/postgres/base.py622
LOW…s/checkpoint-postgres/langgraph/store/postgres/base.py756
LOW…s/checkpoint-postgres/langgraph/store/postgres/base.py823
LOW…s/checkpoint-postgres/langgraph/store/postgres/base.py915
LOW…s/checkpoint-postgres/langgraph/store/postgres/base.py1043
LOW…s/checkpoint-postgres/langgraph/store/postgres/base.py1088
LOW…s/checkpoint-postgres/langgraph/store/postgres/base.py854
LOWlibs/checkpoint-postgres/tests/test_sync.py125
LOWlibs/checkpoint-postgres/tests/test_async.py143
LOWlibs/checkpoint-postgres/tests/test_store.py34
LOWlibs/checkpoint-postgres/tests/test_store.py803
LOWlibs/langgraph/langgraph/types.py793
LOWlibs/langgraph/langgraph/pregel/_draw.py42
LOWlibs/langgraph/langgraph/pregel/_read.py222
LOWlibs/langgraph/langgraph/pregel/_call.py200
LOWlibs/langgraph/langgraph/pregel/_algo.py232
LOWlibs/langgraph/langgraph/pregel/_algo.py524
LOWlibs/langgraph/langgraph/pregel/_algo.py1280
LOWlibs/langgraph/langgraph/pregel/_algo.py1348
LOWlibs/langgraph/langgraph/pregel/_io.py56
LOWlibs/langgraph/langgraph/pregel/_io.py81
LOWlibs/langgraph/langgraph/pregel/_io.py118
LOWlibs/langgraph/langgraph/pregel/remote.py90
LOWlibs/langgraph/langgraph/pregel/remote.py757
LOWlibs/langgraph/langgraph/pregel/_checkpoint.py61
LOWlibs/langgraph/langgraph/pregel/_loop.py836
LOWlibs/langgraph/langgraph/pregel/_loop.py1393
LOWlibs/langgraph/langgraph/pregel/_write.py172
LOWlibs/langgraph/langgraph/pregel/_messages.py426
LOWlibs/langgraph/langgraph/pregel/_messages.py106
LOWlibs/langgraph/langgraph/pregel/_messages.py191
LOWlibs/langgraph/langgraph/pregel/_messages.py223
LOWlibs/langgraph/langgraph/pregel/_messages.py307
LOWlibs/langgraph/langgraph/pregel/_messages.py336
LOWlibs/langgraph/langgraph/pregel/debug.py209
LOWlibs/langgraph/langgraph/pregel/_validate.py13
LOWlibs/langgraph/langgraph/pregel/_validate.py110
LOWlibs/langgraph/langgraph/pregel/_executor.py186
LOWlibs/langgraph/langgraph/pregel/main.py4151
LOWlibs/langgraph/langgraph/pregel/main.py1074
LOWlibs/langgraph/langgraph/pregel/main.py1588
LOWlibs/langgraph/langgraph/pregel/main.py2039
LOWlibs/langgraph/langgraph/pregel/main.py2626
LOWlibs/langgraph/langgraph/pregel/main.py3032
LOWlibs/langgraph/langgraph/pregel/main.py3803
LOWlibs/langgraph/langgraph/pregel/main.py3980
LOWlibs/langgraph/langgraph/pregel/main.py1638
LOWlibs/langgraph/langgraph/pregel/main.py2089
LOWlibs/langgraph/langgraph/pregel/_runner.py616
LOWlibs/langgraph/langgraph/pregel/_runner.py650
LOWlibs/langgraph/langgraph/pregel/_runner.py700
192 more matches not shown…
Docstring Block Structure37 hits · 185 pts
SeverityFileLineSnippet
HIGH…oint-postgres/langgraph/checkpoint/postgres/shallow.py306Get a checkpoint tuple from the database. This method retrieves a checkpoint tuple from the Postgres database b
HIGH…oint-postgres/langgraph/checkpoint/postgres/shallow.py381Save a checkpoint to the database. This method saves a checkpoint to the Postgres database. The checkpoint is a
HIGH…int-postgres/langgraph/checkpoint/postgres/__init__.py120List checkpoints from the database. This method retrieves a list of checkpoint tuples from the Postgres databas
HIGH…int-postgres/langgraph/checkpoint/postgres/__init__.py193Get a checkpoint tuple from the database. This method retrieves a checkpoint tuple from the Postgres database b
HIGH…int-postgres/langgraph/checkpoint/postgres/__init__.py270Save a checkpoint to the database. This method saves a checkpoint to the Postgres database. The checkpoint is a
HIGHlibs/langgraph/langgraph/types.py812Interrupt the graph with a resumable exception from within a node. The `interrupt` function enables human-in-the-lo
HIGHlibs/langgraph/langgraph/pregel/main.py1593Apply updates to the graph state in bulk. Requires a checkpointer to be set. Args: config: The conf
HIGHlibs/langgraph/langgraph/pregel/main.py2044Asynchronously apply updates to the graph state in bulk. Requires a checkpointer to be set. Args: c
HIGHlibs/langgraph/langgraph/stream/_types.py239Schedule a coroutine tied to this transformer's lifecycle. The mux holds the task reference, awaits all schedul
HIGHlibs/langgraph/langgraph/stream/run_stream.py196Iterate multiple projections in arrival order, yielding ``(name, item)``. Items are ordered by a monotonic push
HIGHlibs/langgraph/langgraph/stream/stream_channel.py246Subscribe and return `n` independent sync iterators. Each branch has its own buffer; items pulled from the
HIGHlibs/langgraph/langgraph/stream/stream_channel.py289Subscribe and return `n` independent async iterators. Caller-driven fan-out: each branch's `__anext__` either p
HIGHlibs/langgraph/langgraph/graph/state.py916Add a directed edge from the start node (or list of start nodes) to the end node. When a single start node is p
HIGHlibs/langgraph/langgraph/graph/state.py1026Add a sequence of nodes that will be executed in the provided order. Args: nodes: A sequence of `St
HIGHlibs/checkpoint/langgraph/checkpoint/base/__init__.py240Fetch a checkpoint tuple using the given configuration. Args: config: Configuration specifying whic
HIGHlibs/checkpoint/langgraph/checkpoint/base/__init__.py261List checkpoints that match the given criteria. Args: config: Base configuration for filtering chec
HIGHlibs/checkpoint/langgraph/checkpoint/base/__init__.py284Store a checkpoint with its configuration and metadata. Args: config: Configuration for the checkpo
HIGHlibs/checkpoint/langgraph/checkpoint/base/__init__.py430Asynchronously fetch a checkpoint tuple using the given configuration. Args: config: Configuration
HIGHlibs/checkpoint/langgraph/checkpoint/base/__init__.py451Asynchronously list checkpoints that match the given criteria. Args: config: Base configuration for
HIGHlibs/checkpoint/langgraph/checkpoint/base/__init__.py475Asynchronously store a checkpoint with its configuration and metadata. Args: config: Configuration
HIGHlibs/checkpoint/langgraph/store/base/embed.py163Embed a list of texts into vectors. Args: texts: list of texts to convert to embeddings. R
HIGHlibs/sdk-py/langgraph_sdk/encryption/__init__.py78Register a blob encryption handler. The handler will be called to encrypt opaque data like checkpoint blobs.
HIGHlibs/sdk-py/langgraph_sdk/encryption/__init__.py107Register the JSON encryption handler. Example: ```python @encryption.encrypt.json
HIGHlibs/sdk-py/langgraph_sdk/encryption/__init__.py145Register a blob decryption handler. The handler will be called to decrypt opaque data like checkpoint blobs.
HIGHlibs/sdk-py/langgraph_sdk/encryption/__init__.py174Register the JSON decryption handler. Example: ```python @encryption.decrypt.json
HIGHlibs/sdk-py/langgraph_sdk/auth/__init__.py226Register an authentication handler function. The authentication handler is responsible for verifying credential
HIGHlibs/prebuilt/langgraph/prebuilt/tool_node.py173Replace the request with a new request with the given overrides. Returns a new `ToolCallRequest` instance with
HIGHlibs/prebuilt/langgraph/prebuilt/tool_node.py403Generate error message content based on exception handling configuration. This function centralizes error message g
HIGHlibs/prebuilt/langgraph/prebuilt/tool_node.py445Infer exception types handled by a custom error handler function. This function analyzes the type annotations of a
HIGHlibs/prebuilt/langgraph/prebuilt/tool_node.py928Execute tool call with configured error handling. Args: request: Tool execution request.
HIGHlibs/prebuilt/langgraph/prebuilt/tool_node.py1075Execute tool call asynchronously with configured error handling. Args: request: Tool execution requ
HIGHlibs/prebuilt/langgraph/prebuilt/tool_node.py1321Inject graph state, store, and runtime into tool call arguments. This is an internal method that enables tools
HIGHlibs/prebuilt/langgraph/prebuilt/tool_node.py1586Conditional routing function for tool-calling workflows. This utility function implements the standard conditional
HIGH…ckpoint-sqlite/langgraph/checkpoint/sqlite/__init__.py100Create a new SqliteSaver instance from a connection string. Args: conn_string: The SQLite connectio
HIGH…ckpoint-sqlite/langgraph/checkpoint/sqlite/__init__.py192Get a checkpoint tuple from the database. This method retrieves a checkpoint tuple from the SQLite database bas
HIGH…ckpoint-sqlite/langgraph/checkpoint/sqlite/__init__.py303List checkpoints from the database. This method retrieves a list of checkpoint tuples from the SQLite database
HIGH…ckpoint-sqlite/langgraph/checkpoint/sqlite/__init__.py394Save a checkpoint to the database. This method saves a checkpoint to the SQLite database. The checkpoint is ass
Excessive Try-Catch Wrapping143 hits · 145 pts
SeverityFileLineSnippet
LOW…ckpoint-postgres/langgraph/checkpoint/postgres/base.py35except Exception:
LOW…bs/checkpoint-postgres/langgraph/store/postgres/aio.py271 except Exception as e:
LOW…bs/checkpoint-postgres/langgraph/store/postgres/aio.py349 except Exception as exc:
LOW…s/checkpoint-postgres/langgraph/store/postgres/base.py864 except Exception as exc:
LOW…s/checkpoint-postgres/langgraph/store/postgres/base.py869 except Exception as exc:
LOW…s/checkpoint-postgres/langgraph/store/postgres/base.py1118 except Exception as e:
LOW…s/checkpoint-postgres/langgraph/store/postgres/base.py1140 except Exception as e:
LOW…s/checkpoint-postgres/langgraph/store/postgres/base.py1242 except Exception as e:
MEDIUM…s/checkpoint-postgres/langgraph/store/postgres/base.py854def _sweep_loop() -> None:
LOWlibs/langgraph/langgraph/pregel/_read.py187 except Exception:
LOWlibs/langgraph/langgraph/pregel/_call.py79 except Exception:
LOWlibs/langgraph/langgraph/pregel/_remote_run_stream.py233 except Exception:
LOWlibs/langgraph/langgraph/pregel/_remote_run_stream.py237 except Exception:
LOWlibs/langgraph/langgraph/pregel/_remote_run_stream.py363 except Exception:
LOWlibs/langgraph/langgraph/pregel/_remote_run_stream.py367 except Exception:
LOWlibs/langgraph/langgraph/pregel/_algo.py647 except Exception as exc:
LOWlibs/langgraph/langgraph/pregel/_runner.py222 except Exception as exc:
LOWlibs/langgraph/langgraph/pregel/_runner.py350 except Exception as exc:
LOWlibs/langgraph/langgraph/pregel/_runner.py414 except Exception as exc:
LOWlibs/langgraph/langgraph/pregel/_runner.py564 except Exception as exc:
LOWlibs/langgraph/langgraph/pregel/_runner.py940 except Exception as exc:
LOWlibs/langgraph/langgraph/pregel/_retry.py413 except Exception:
LOWlibs/langgraph/langgraph/pregel/_retry.py641 except Exception as exc:
LOWlibs/langgraph/langgraph/pregel/_retry.py762 except Exception as writer_exc:
LOWlibs/langgraph/langgraph/pregel/_retry.py795 except Exception as exc:
LOWlibs/langgraph/langgraph/_internal/_serde.py224 except Exception:
LOWlibs/langgraph/langgraph/_internal/_serde.py235 except Exception:
LOWlibs/langgraph/langgraph/stream/transformers.py897 except Exception:
LOWlibs/langgraph/langgraph/stream/transformers.py913 except Exception:
LOWlibs/langgraph/langgraph/stream/run_stream.py127 except Exception as e:
LOWlibs/langgraph/langgraph/stream/run_stream.py144 except Exception:
LOWlibs/langgraph/langgraph/stream/run_stream.py419 except Exception as e:
LOWlibs/langgraph/langgraph/stream/run_stream.py442 except Exception:
LOWlibs/langgraph/langgraph/stream/stream_channel.py334 except Exception as e:
LOWlibs/langgraph/langgraph/graph/_branch.py115 except Exception:
LOWlibs/langgraph/langgraph/channels/binop.py77 except Exception:
LOWlibs/langgraph/tests/conftest.py86 except Exception:
LOWlibs/langgraph/tests/test_delta_channel_benchmark.py227 except Exception:
LOWlibs/langgraph/tests/test_remote_graph_v3.py586 except Exception:
MEDIUMlibs/langgraph/tests/test_pregel_async.py266def main():
LOWlibs/langgraph/tests/test_pregel_async.py8750 except Exception as e:
LOWlibs/langgraph/tests/test_serde_allowlist.py83 except Exception:
MEDIUMlibs/langgraph/tests/test_serde_allowlist.py80def test_curated_core_allowlist_includes_messages() -> None:
LOWlibs/langgraph/tests/test_tracing_interops.py51 except Exception as e:
LOWlibs/langgraph/tests/test_pregel.py8324 except Exception as e:
LOWlibs/checkpoint/langgraph/checkpoint/memory/__init__.py665 except Exception:
LOWlibs/checkpoint/langgraph/checkpoint/memory/__init__.py701 except Exception:
LOWlibs/checkpoint/langgraph/checkpoint/serde/jsonplus.py207 except Exception as exc:
LOWlibs/checkpoint/langgraph/checkpoint/serde/jsonplus.py652 except Exception:
LOWlibs/checkpoint/langgraph/checkpoint/serde/jsonplus.py665 except Exception:
LOWlibs/checkpoint/langgraph/checkpoint/serde/jsonplus.py676 except Exception:
LOWlibs/checkpoint/langgraph/checkpoint/serde/jsonplus.py689 except Exception:
LOWlibs/checkpoint/langgraph/checkpoint/serde/jsonplus.py702 except Exception:
LOWlibs/checkpoint/langgraph/checkpoint/serde/jsonplus.py704 except Exception:
LOWlibs/checkpoint/langgraph/checkpoint/serde/jsonplus.py722 except Exception:
LOWlibs/checkpoint/langgraph/checkpoint/serde/jsonplus.py724 except Exception:
LOWlibs/checkpoint/langgraph/checkpoint/serde/jsonplus.py740 except Exception:
LOWlibs/checkpoint/langgraph/checkpoint/serde/jsonplus.py766 except Exception:
LOWlibs/checkpoint/langgraph/checkpoint/serde/jsonplus.py779 except Exception:
LOWlibs/checkpoint/langgraph/checkpoint/serde/jsonplus.py790 except Exception:
83 more matches not shown…
Slop Phrases13 hits · 36 pts
SeverityFileLineSnippet
LOW…int-postgres/langgraph/checkpoint/postgres/__init__.py158 # if we change this to use .stream() we need to make sure to close the cursor
LOW…eckpoint-postgres/langgraph/checkpoint/postgres/aio.py147 # if we change this to use .stream() we need to make sure to close the cursor
MEDIUMlibs/langgraph/tests/test_large_cases.py1728 # meaning you can use it as you would any other runnable
MEDIUMlibs/langgraph/tests/test_large_cases.py2492 # meaning you can use it as you would any other runnable
MEDIUMlibs/langgraph/tests/test_large_cases.py3218 # meaning you can use it as you would any other runnable
MEDIUMlibs/langgraph/tests/test_large_cases_async.py1449 # meaning you can use it as you would any other runnable
MEDIUMlibs/langgraph/tests/test_large_cases_async.py2164 # meaning you can use it as you would any other runnable
MEDIUMlibs/prebuilt/langgraph/prebuilt/chat_agent_executor.py994 # meaning you can use it as you would any other runnable
MEDIUMlibs/cli/examples/graphs_reqs_b/graphs_submod/agent.py99# meaning you can use it as you would any other runnable
MEDIUMlibs/cli/examples/graph_prerelease_reqs_fail/agent.py88# meaning you can use it as you would any other runnable
MEDIUMlibs/cli/examples/graph_prerelease_reqs/agent.py87# meaning you can use it as you would any other runnable
MEDIUMlibs/cli/examples/graphs/agent.py95# meaning you can use it as you would any other runnable
MEDIUMlibs/cli/examples/graphs_reqs_a/graphs_submod/agent.py98# meaning you can use it as you would any other runnable
Redundant / Tautological Comments18 hits · 26 pts
SeverityFileLineSnippet
LOWdocs/generate_redirects.py97 # Check if path has a file extension (e.g., .txt, .xml)
LOWlibs/langgraph/langgraph/pregel/_algo.py488 # Check if any processes should be run in next step
LOWlibs/langgraph/langgraph/graph/state.py839 # Check if it's a Command type
LOWlibs/langgraph/tests/test_pregel_async.py8415 # Check if there are only two checkpoints
LOWlibs/langgraph/tests/test_pregel.py7948 # Check if there are only two checkpoints
LOWlibs/prebuilt/langgraph/prebuilt/tool_node.py546 # Check if error location contains any injected argument
LOWlibs/prebuilt/langgraph/prebuilt/tool_node.py1001 # Check if this error should be handled
LOWlibs/prebuilt/langgraph/prebuilt/tool_node.py1148 # Check if this error should be handled
LOWlibs/cli/langgraph_cli/config.py919 # Check if it's a file path
LOWlibs/cli/langgraph_cli/templates.py143 # Check if path exists and is not empty
LOWlibs/cli/langgraph_cli/cli.py618 # Check if the .env file exists in the same directory as the Dockerfile
LOWlibs/cli/tests/unit_tests/cli/test_cli.py680 # Check if Dockerfile was created
LOWlibs/cli/tests/unit_tests/cli/test_cli.py724 # Check if Dockerfile was created
LOWlibs/cli/tests/unit_tests/cli/test_cli.py795 # Check if Dockerfile, .dockerignore, docker-compose.yml, and .env were created
LOWlibs/cli/tests/unit_tests/cli/test_cli.py981 # Check if Dockerfile was created and contains correct FROM line
LOWlibs/cli/tests/unit_tests/cli/test_cli.py1021 # Check if Dockerfile was created and contains correct FROM line
LOWlibs/cli/tests/unit_tests/cli/test_cli.py1057 # Check if Dockerfile was created and contains correct FROM line
LOWlibs/checkpoint-sqlite/tests/test_store.py471 # Check if vector tables exist
Over-Commented Block25 hits · 24 pts
SeverityFileLineSnippet
LOW…ckpoint-postgres/langgraph/checkpoint/postgres/base.py181#
LOWlibs/langgraph/langgraph/pregel/_loop.py201 # local `futs` then reset to `[]` and wait/gather) before putting the
LOWlibs/langgraph/langgraph/pregel/_loop.py221 _exit_delta_writes: list[tuple[int, str, str, Any]] | None = None
LOWlibs/langgraph/langgraph/pregel/_loop.py861
LOWlibs/langgraph/langgraph/pregel/_loop.py941 # save a fork checkpoint so the replayed execution creates a
LOWlibs/langgraph/langgraph/pregel/_loop.py1021 # Pass the resolved before-bound checkpoint ID so subgraphs can
LOWlibs/langgraph/langgraph/pregel/_loop.py1061 self._push_graph_lifecycle_event("resume")
LOWlibs/langgraph/langgraph/pregel/_loop.py1081 # Each delta channel tracks a (updates, supersteps) tuple:
LOWlibs/langgraph/langgraph/_internal/_constants.py61# holds a callback to be called when a node is finished
LOWlibs/langgraph/langgraph/stream/transformers.py401
LOWlibs/langgraph/tests/test_large_cases.py2461 # Set the entrypoint as `agent`
LOWlibs/langgraph/tests/test_large_cases_async.py2141 "agent",
LOW…s/langgraph/tests/test_stream_lifecycle_transformer.py441# Subagent discrimination via lc_agent_name transition
LOWlibs/sdk-py/integration/docker-compose.yml61
LOWlibs/cli/js-examples/src/agent/graph.ts81 return "__end__";
LOWlibs/cli/examples/graphs_reqs_b/graphs_submod/agent.py81 # END is a special node marking that the graph should finish.
LOWlibs/cli/examples/graph_prerelease_reqs_fail/agent.py61# We now add a conditional edge
LOWlibs/cli/examples/graph_prerelease_reqs/agent.py61workflow.add_conditional_edges(
LOWlibs/cli/examples/graph_prerelease_reqs/agent.py81# We now add a normal edge from `tools` to `agent`.
LOWlibs/cli/examples/graphs/storm.py401# Using turbo preview since the context can get quite long
LOWlibs/cli/examples/graphs/agent.py61workflow.add_node("agent", call_model)
LOW.github/workflows/release.yml161 - uses: actions/checkout@v6
LOW.github/workflows/tag-external-issues.yml1# Automatically tag issues as "external" or "internal" based on whether
LOW.github/workflows/tag-external-prs.yml1# Automatically tag pull requests as "external" or "internal" based on
LOW.github/workflows/require_issue_link.yml1# Require external PRs to reference an approved issue (e.g. Fixes #NNN) and
AI Slop Vocabulary6 hits · 16 pts
SeverityFileLineSnippet
MEDIUMlibs/sdk-py/tests/test_api_parity.py83 # Use inspect.signature for parameter names (robust across versions)
MEDIUMlibs/sdk-py/tests/streaming/test_sync_projections.py123# Task 10.7 — comprehensive sync messages projection tests
MEDIUMlibs/sdk-py/tests/streaming/test_sync_projections.py292# Task 10.7 — comprehensive sync tool_calls projection tests
MEDIUMlibs/sdk-py/langgraph_sdk/schema.py448 """Whether to persist the stream chunks in order to resume the stream later."""
LOWlibs/prebuilt/tests/test_on_tool_call.py216 # Don't call execute, just return None (invalid)
MEDIUMlibs/cli/examples/graphs/storm.py136 """You need to select a diverse (and distinct) group of Wikipedia editors who will work together to create a
Dead Code7 hits · 14 pts
SeverityFileLineSnippet
MEDIUMlibs/checkpoint/langgraph/checkpoint/base/__init__.py466
MEDIUMlibs/sdk-py/tests/streaming/test_sync_thread_stream.py137
MEDIUMlibs/sdk-py/tests/streaming/test_sync_thread_stream.py208
MEDIUMlibs/sdk-py/tests/streaming/test_transport_ws.py484
MEDIUMlibs/sdk-py/tests/streaming/test_controller.py284
MEDIUMlibs/sdk-py/tests/streaming/test_controller.py329
MEDIUM…ckpoint-sqlite/langgraph/checkpoint/sqlite/__init__.py609
Fake / Example Data12 hits · 10 pts
SeverityFileLineSnippet
LOWlibs/sdk-py/langgraph_sdk/_async/store.py213 filter={"author": "John Doe"},
LOWlibs/sdk-py/langgraph_sdk/_async/store.py230 "author": "John Doe"
LOWlibs/sdk-py/langgraph_sdk/_sync/store.py213 filter={"author": "John Doe"},
LOWlibs/sdk-py/langgraph_sdk/_sync/store.py229 "author": "John Doe"
LOWlibs/checkpoint-sqlite/tests/test_store.py1004 {"title": "Doc 1", "author": "John Doe", "tags": ["important"]},
LOWlibs/checkpoint-sqlite/tests/test_store.py1006 {"title": "Report A", "author": "John Doe", "tags": ["final"]},
LOWlibs/checkpoint-sqlite/tests/test_store.py1039 john_items = store.search((base,), filter={"author": "John Doe"})
LOWlibs/checkpoint-sqlite/tests/test_store.py1041 assert all(item.value["author"] == "John Doe" for item in john_items)
LOWlibs/checkpoint-sqlite/tests/test_async_store.py674 {"title": "Doc 1", "author": "John Doe", "tags": ["important"]},
LOWlibs/checkpoint-sqlite/tests/test_async_store.py676 {"title": "Report A", "author": "John Doe", "tags": ["final"]},
LOWlibs/checkpoint-sqlite/tests/test_async_store.py709 john_items = await store.asearch((base,), filter={"author": "John Doe"})
LOWlibs/checkpoint-sqlite/tests/test_async_store.py711 assert all(item.value["author"] == "John Doe" for item in john_items)
Magic Placeholder Names1 hit · 5 pts
SeverityFileLineSnippet
HIGHlibs/cli/langgraph_cli/cli.py626 "# LANGSMITH_API_KEY=your-api-key",
Verbosity Indicators1 hit · 2 pts
SeverityFileLineSnippet
LOW…ckpoint/conformance/spec/test_delta_channel_history.py181 # Step 1: plain value (migration case — old checkpoint before delta)
Overly Generic Function Names1 hit · 1 pts
SeverityFileLineSnippet
LOWlibs/prebuilt/tests/test_validation_node.py15def my_function(some_val: int, some_other_val: str) -> str: