Fix oversight of rebace

patroni · Dec 1, 2023 · 63ffb63 · 63ffb63
1 parent d7b4b4e
commit 63ffb63
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/patroni/postgresql/citus.py b/patroni/postgresql/citus.py
@@ -387,8 +387,8 @@ def schedule_cache_rebuild(self) -> None:
 
     def on_demote(self) -> None:
         with self._condition:
-            self._pg_dist_node.clear()
-            empty_tasks: List[PgDistNode] = []
+            self._pg_dist_group.clear()
+            empty_tasks: List[PgDistTask] = []
             self._tasks[:] = empty_tasks
             self._in_flight = None