Throttle 'output produced' messages to Manager

flamenco_worker/worker.py

@@ -5,6 +5,7 @@ import functools
 import itertools
 import pathlib
 import tempfile
+import time
 import traceback
 import typing
 
@@ -149,6 +150,8 @@ class FlamencoWorker:
 
     _log = attrs_extra.log('%s.FlamencoWorker' % __name__)
 
+    _last_output_produced = 0.0  # seconds since epoch
+
     @property
     def active_task_id(self) -> typing.Optional[str]:
         """Returns the task ID, but only if it is currently executing; returns None otherwise."""
@@ -663,8 +666,17 @@ class FlamencoWorker:
 
         This performs a HTTP POST in a background task, returning as soon as
         the task is scheduled.
+
+        Only sends an update every X seconds, to avoid sending too many
+        requests when we output frames rapidly.
         """
 
+        now = time.time()
+        if now - self._last_output_produced < 30:
+            self._log.debug('Throttling POST to Manager /output-produced endpoint')
+            return
+        self._last_output_produced = now
+
         async def do_post():
             try:
                 self._log.info('Sending %i path(s) to Manager', len(paths))