Do not pause standby partitions after recovery

TotalWineLabs · Dec 14, 2023 · d60388a · d60388a
1 parent 4f73de8
commit d60388a
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/faust/tables/recovery.py b/faust/tables/recovery.py
@@ -484,8 +484,6 @@ async def _restart_recovery(self) -> None:
                     self.log.info('Done reading from changelog topics')
                     if active_tps:
                         T(consumer.pause_partitions)(active_tps)
-                    if standby_tps:
-                        T(consumer.pause_partitions)(standby_tps)
                 else:
                     self.log.info('Resuming flow...')
                     T(consumer.resume_flow)()