L-110 Continue flushing after shutdown until pipe is empty (#17)

logtail · Oct 12, 2023 · 24034a0 · 24034a0
1 parent b24acd1
commit 24034a0
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/logtail/__init__.py b/logtail/__init__.py
@@ -5,6 +5,6 @@
 from .helpers import LogtailContext, DEFAULT_CONTEXT
 from .formatter import LogtailFormatter
 
-__version__ = '0.2.6'
+__version__ = '0.2.7'
 
 context = DEFAULT_CONTEXT
diff --git a/logtail/flusher.py b/logtail/flusher.py
@@ -67,7 +67,7 @@ def step(self):
             if response.status_code == 500 and getattr(response, "exception") != None:
                 print('Failed to send logs to Better Stack after {} retries: {}'.format(len(RETRY_SCHEDULE), response.exception))
 
-        if shutdown:
+        if shutdown and self.pipe.empty():
             sys.exit(0)
 
 

diff --git a/setup.py b/setup.py
@@ -3,7 +3,7 @@
 from setuptools import setup
 
 
-VERSION = '0.2.6'
+VERSION = '0.2.7'
 ROOT_DIR = os.path.dirname(__file__)
 
 REQUIREMENTS = [