From 8b42793d30b9816eef1012e8dd8f2fd4ea9bc8b1 Mon Sep 17 00:00:00 2001 From: Caspar Broekhuizen Date: Thu, 9 Oct 2025 14:37:13 -0700 Subject: [PATCH] style(langgraph): remove prints --- libs/langgraph/langgraph/pregel/_loop.py | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/libs/langgraph/langgraph/pregel/_loop.py b/libs/langgraph/langgraph/pregel/_loop.py index e7f9ad88f..5f096da2d 100644 --- a/libs/langgraph/langgraph/pregel/_loop.py +++ b/libs/langgraph/langgraph/pregel/_loop.py @@ -480,8 +480,6 @@ class PregelLoop: return False # prepare next tasks - print("checkpoint_pending_writes before: ", self.checkpoint_pending_writes) - self.tasks = prepare_next_tasks( self.checkpoint, self.checkpoint_pending_writes, @@ -501,8 +499,6 @@ class PregelLoop: cache_policy=self.cache_policy, ) - print("checkpoint_pending_writes after: ", self.checkpoint_pending_writes) - resume_map = self.config.get(CONF, {}).get(CONFIG_KEY_RESUME_MAP, {}) if resume_map: skipped_interrupt_ids = self._pending_interrupts() - set(resume_map) @@ -592,7 +588,7 @@ class PregelLoop: if self.skipped_task_ids: # raise early GraphInterrupt for skipped tasks. # since we know len(resumes) < len(interrupts) for these tasks, we - # can prevent unnecessary node re-execution by raising preemptively + # can prevent unnecessary node re-execution by raising early interrupts = [] for task_id, channel, value in self.checkpoint_pending_writes: if channel == INTERRUPT and task_id in self.skipped_task_ids: