Merge pull request fluent#99 from arcivanov/issue_97

repeatedly · web-flow · commit 4aec4e8954ec · 2017-12-04T10:49:34.000+09:00
FluentHandler incorrectly timestamps the records
diff --git a/fluent/handler.py b/fluent/handler.py
@@ -179,7 +179,12 @@ def getSenderInstance(self, tag, host, port, timeout, verbose,
 
     def emit(self, record):
         data = self.format(record)
-        return self.sender.emit(None, data)
+        _sender = self.sender
+        return _sender.emit_with_time(None,
+                                      sender.EventTime(record.created)
+                                      if _sender.nanosecond_precision
+                                      else int(record.created),
+                                      data)
 
     def close(self):
         self.acquire()
