Skip to content

Commit

Permalink
Fix for writebatch when not in recovery for standby writes (#56)
Browse files Browse the repository at this point in the history
  • Loading branch information
patkivikram authored Dec 17, 2020
1 parent ccaf0a7 commit 979ca5a
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion faust/tables/recovery.py
Original file line number Diff line number Diff line change
Expand Up @@ -724,7 +724,7 @@ async def _maybe_signal_recovery_end(timeout=False, timeout_count=0) -> None:
# the aiokafka consumer position and draining of the queue
if timeout and self.app.in_transaction and timeout_count > 1:
await detect_aborted_tx()
if not self.active_remaining_total():
if not self.active_remaining_total() and self.in_recovery:
# apply anything stuck in the buffers
self.flush_buffers()
self._set_recovery_ended()
Expand Down

0 comments on commit 979ca5a

Please sign in to comment.