Fix oversight of rebace

This commit is contained in:
Alexander Kukushkin
2023-12-01 11:35:20 +01:00
parent d7b4b4e8a9
commit 63ffb6320f
+2 -2
View File
@@ -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