Limit size of "stuck" services' queues

Signed-off-by: Jim Easterbrook <jim@jim-easterbrook.me.uk>
jim-easterbrook · Aug 24, 2018 · 82498d3 · 82498d3
1 parent 15bd4d0
commit 82498d3
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/src/pywws/__init__.py b/src/pywws/__init__.py
@@ -1,3 +1,3 @@
 __version__ = '18.8.0'
-_release = '1591'
-_commit = '98c4fe5'
+_release = '1592'
+_commit = '15bd4d0'
diff --git a/src/pywws/service/__init__.py b/src/pywws/service/__init__.py
@@ -182,6 +182,8 @@ def do_catchup(self, do_all=False):
             self.queue_data(data['idx'], data, False)
 
     def upload(self, live_data=None, test_mode=False, option=''):
+        if self.queue.full():
+            return
         if test_mode:
             idx = self.context.calib_data.before(datetime.max)
         else:
@@ -202,6 +204,8 @@ def do_catchup(self, do_all=False):
         pass
 
     def upload(self, live_data=None, test_mode=False, option=''):
+        if self.queue.full():
+            return
         if live_data:
             data = live_data
         else:
@@ -235,6 +239,8 @@ def do_catchup(self, do_all=False):
             self.upload(option='CATCHUP')
 
     def upload(self, live_data=None, option=''):
+        if self.queue.full():
+            return
         self.queue.append(option)
 
     def upload_batch(self):