fixed bug. add prefix for extra fields while init Formatter

Author: oschulzSam

logstash_async/__init__.py

@@ -3,7 +3,7 @@
 # This software may be modified and distributed under the terms
 # of the MIT license.  See the LICENSE file for details.
 
-__version__ = '2.3.0'
+__version__ = '2.3.1'
 
 # When using an in-memory only cache, this persists the cache through
 # thread failures, shutdowns, and restarts.

logstash_async/formatter.py

@@ -38,6 +38,8 @@ def __init__(
         self._tags = tags if tags is not None else []
         self._extra_prefix = extra_prefix
         self._extra = extra
+        self._format_extra_fields()
+
         self._ensure_ascii = ensure_ascii
         self._metadata = metadata
 
@@ -98,8 +100,6 @@ def format(self, record):
         # record fields
         dynamic_extra_fields = self._get_record_fields(record)
         message.update(dynamic_extra_fields)
-        # prepare static extra fields
-        self._format_extra_fields()
         if self._extra:
             message.update(self._extra)
 

setup.py

@@ -9,7 +9,7 @@
 import sys
 
 NAME = 'python-logstash-async'
-VERSION = '2.3.0'
+VERSION = '2.3.1'
 
 here = path.abspath(path.dirname(__file__))
 with open(path.join(here, 'README.rst'), 'rb') as f: