diff --git a/libs/langgraph/langgraph/pregel/__init__.py b/libs/langgraph/langgraph/pregel/__init__.py index 93251576a..661262071 100644 --- a/libs/langgraph/langgraph/pregel/__init__.py +++ b/libs/langgraph/langgraph/pregel/__init__.py @@ -544,7 +544,6 @@ class Pregel(PregelProtocol): self.config_type = config_type self.input_model = input_model self.config = config - self.name = name if auto_validate: self.validate() @@ -2561,7 +2560,6 @@ class Pregel(PregelProtocol): stream.put_nowait, ((), "custom", c) ) ) - async with AsyncPregelLoop( input, input_model=self.input_model, diff --git a/libs/langgraph/langgraph/pregel/algo.py b/libs/langgraph/langgraph/pregel/algo.py index ab9668ab1..cc9a45e59 100644 --- a/libs/langgraph/langgraph/pregel/algo.py +++ b/libs/langgraph/langgraph/pregel/algo.py @@ -452,7 +452,6 @@ def prepare_next_tasks( # Check if any processes should be run in next step # If so, prepare the values to be passed to them for name in candidate_nodes: - # Check if we know which channels have been updated. if task := prepare_single_task( (PULL, name), None,