Merge pull request #3 from spoqa/fix-double-encode

Not to encode the payload
spoqa · Sep 7, 2018 · fca3233 · fca3233
2 parents 3961daf + ff9a664
commit fca3233
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/CHANGES.rst b/CHANGES.rst
@@ -6,6 +6,8 @@ Changelog
 
 To be released
 
+- Fixed the bug caused by doubly encoded record.
+
 
 0.1.0
 =====

diff --git a/firefighter/logging.py b/firefighter/logging.py
@@ -17,7 +17,6 @@
 from __future__ import (absolute_import, division, print_function,
                         unicode_literals)
 
-import base64
 import logging
 import threading
 import time
@@ -108,7 +107,7 @@ def _submit_batch(self, batch, delivery_stream_name, max_retries=5):
         response = None
         kwargs = {
             'DeliveryStreamName': delivery_stream_name,
-            'Records': [{'Data': base64.b64encode(data)} for data in batch]
+            'Records': [{'Data': data} for data in batch]
         }
         for retry in range(max_retries):
             try: