We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 48c44eb + df0493a commit e861befCopy full SHA for e861bef
fluvii/fluvii_app/fluvii_multi_msg_app.py
@@ -16,5 +16,6 @@ def _handle_message(self, **kwargs):
16
17
def _finalize_app_batch(self):
18
# Do it at the end of consuming instead!
19
- self._app_function(self.transaction, *self._app_function_arglist)
+ if self.transaction.messages():
20
+ self._app_function(self.transaction, *self._app_function_arglist)
21
super()._finalize_app_batch()
0 commit comments