Fix

2026-08-28 18:59:42 +02:00 · 2025-01-22 16:02:09 -08:00
parent 17dacb83a2
commit cbad17fa7d
1 changed files with 3 additions and 1 deletions
@@ -228,7 +228,9 @@ class PregelLoop(LoopProtocol):
        if self.stream is not None and CONFIG_KEY_STREAM in config[CONF]:
            self.stream = DuplexStream(self.stream, config[CONF][CONFIG_KEY_STREAM])
        scratchpad: Optional[PregelScratchpad] = config[CONF].get(CONFIG_KEY_SCRATCHPAD)
-        if not self.config[CONF].get(CONFIG_KEY_DELEGATE) and scratchpad is not None:
+        if not self.config[CONF].get(CONFIG_KEY_DELEGATE) and isinstance(
+            scratchpad, PregelScratchpad
+        ):
            if scratchpad.subgraph_counter:
                self.config = patch_configurable(
                    self.config,