From 63ffb6320f552c99a4d0b1b205b37f8f0abf5735 Mon Sep 17 00:00:00 2001
From: Alexander Kukushkin <cyberdemn@gmail.com>
Date: Fri, 1 Dec 2023 11:10:04 +0100
Subject: [PATCH] Fix oversight of rebace

---
 patroni/postgresql/citus.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/patroni/postgresql/citus.py b/patroni/postgresql/citus.py
index 4b83aed2..7499c5e2 100644
--- a/patroni/postgresql/citus.py
+++ b/patroni/postgresql/citus.py
@@ -387,8 +387,8 @@ class CitusHandler(Thread):
 
     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