Worker: Add timestamp to log entries.

packages/flamenco-worker-python/flamenco_worker/tz.py

+import datetime
+
+
+class tzutc(datetime.tzinfo):
+    """tzinfo subclass for UTC time."""
+
+    def utcoffset(self, dt):
+        return datetime.timedelta(0)
+
+    def dst(self, dt):
+        return datetime.timedelta(0)
+
+    def tzname(self, dt):
+        return "UTC"
+
+    def is_ambiguous(self, dt):
+        return False
+
+    def __eq__(self, other):
+        if not isinstance(other, tzutc):
+            return NotImplemented
+
+        return True
+
+    __hash__ = None
+
+    def __ne__(self, other):
+        return not (self == other)
+
+    def __repr__(self):
+        return "%s()" % self.__class__.__name__

packages/flamenco-worker-python/flamenco_worker/worker.py

@@ -237,7 +237,10 @@ class FlamencoWorker:
     def register_log(self, log_entry):
         """Registers a log entry, and possibly sends all queued log entries to upstream Master."""
 
-        self.queued_log_entries.append(log_entry)
+        from . import tz
+
+        now = datetime.datetime.now(tz.tzutc()).isoformat()
+        self.queued_log_entries.append('%s: %s' % (now, log_entry))
 
         if len(self.queued_log_entries) > PUSH_LOG_MAX_ENTRIES:
             self._log.info('Queued up more than %i log entries, pushing to master',