Skip to content
Snippets Groups Projects
Commit 1ac1d73b authored by Deep Chatterjee's avatar Deep Chatterjee
Browse files

set until_eos=False in listener until fix for autocommit is found

parent dcb16c6c
No related branches found
No related tags found
1 merge request!903Until eos false
......@@ -22,7 +22,7 @@ class IGWNAlertClient(client):
def __init__(self, *args, **kwargs):
super().__init__(*args, **kwargs)
self.batch_size = 1
self.until_eos = True
self.until_eos = False # FIXME: Revert to True when fix for autocommit is found # noqa: E501
self.running = False
self.start_at = StartPosition.LATEST
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment