From 1ac1d73b7162634361fe3c5fbceede14aa58f82e Mon Sep 17 00:00:00 2001
From: Deep Chatterjee <deep.chatterjee@ligo.org>
Date: Thu, 25 Aug 2022 16:14:04 -0500
Subject: [PATCH] set until_eos=False in listener until fix for autocommit is
found
---
gwcelery/igwn_alert/bootsteps.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/gwcelery/igwn_alert/bootsteps.py b/gwcelery/igwn_alert/bootsteps.py
index 1c04033eb..45b7f5fbe 100644
--- a/gwcelery/igwn_alert/bootsteps.py
+++ b/gwcelery/igwn_alert/bootsteps.py
@@ -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
--
GitLab