Merge pull request #21 from rh-marketingops/actual-hotfix

fix the bug for real
rh-marketingops · Nov 14, 2022 · 02d4da7 · 02d4da7
2 parents ffbf3d2 + 47ce2f9
commit 02d4da7
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/fluvii/fluvii_app/fluvii_table_app.py b/fluvii/fluvii_app/fluvii_table_app.py
@@ -93,11 +93,11 @@ def _handle_recovery_message(self):
         self.transaction._update_table_entry_from_changelog()
 
     def _finalize_recovery_batch(self):
-        if self.transaction._pending_table_writes:
+        if not self.transaction.message:
+            raise TransactionNotRequired
+        else:
             self.transaction._table_write(recovery_multiplier=self._recovery_multiplier)  # relay transaction's cached writes to the table's write cache
             self._consumer._init_attrs()
-        else:
-            raise TransactionNotRequired
 
     def _table_recovery_consume_loop(self, checks):
         LOGGER.info(f'Consuming from changelog partitions: {[p.partition for p in self._rebalance_manager.recovery_partitions]}')

diff --git a/setup.py b/setup.py
@@ -23,7 +23,7 @@
 
 setuptools.setup(
     name="fluvii",
-    version="0.2.9",
+    version="0.2.10",
     description="A simple Kafka streams implementation in Python using confluent-kafka-python",
     packages=packages,
     install_requires=install_requires,