This commit is contained in:
Eugene Yurtsev
2025-03-19 15:54:07 -04:00
parent 0e7869eba4
commit 8959f2aec5
2 changed files with 0 additions and 3 deletions
@@ -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,
-1
View File
@@ -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,