Merge branch 'wait-for-standby-recovery' into feature-TwmUpgrades

TotalWineLabs · Dec 27, 2023 · 2c75b0f · 2c75b0f
2 parents 80ca26f + c9bb41c
commit 2c75b0f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/faust/tables/recovery.py b/faust/tables/recovery.py
@@ -876,7 +876,7 @@ def standby_stats(self) -> RecoveryStatsMapping:
                               offsets[tp],
                               highwater - offsets[tp])
             for tp, highwater in self.standby_highwaters.items()
-            if offsets[tp] is not None and highwater - offsets[tp] != 0
+            if offsets[tp] is not None and highwater - offsets[tp] > 0
 
         }