diff --git a/.gitignore b/.gitignore
index a221e9e..9aef113 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,3 +1,4 @@
 __pycache__/
 airbyte_serverless.egg-info/
-dist/
\ No newline at end of file
+dist/
+TODO.md
\ No newline at end of file
diff --git a/airbyte_serverless/sources.py b/airbyte_serverless/sources.py
index 63a4a1d..cd3bce4 100644
--- a/airbyte_serverless/sources.py
+++ b/airbyte_serverless/sources.py
@@ -43,9 +43,10 @@ def _run(self, action, state=None):
             process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.STDOUT, shell=True)
             for line in iter(process.stdout.readline, b""):
                 content = line.decode().strip()
-                if not content:
+                try:
+                    message = json.loads(content)
+                except:
                     continue
-                message = json.loads(content)
                 if message.get('trace', {}).get('error'):
                     raise AirbyteSourceException(json.dumps(message['trace']['error']))
                 yield message
diff --git a/setup.py b/setup.py
index 7d42848..44c4a15 100644
--- a/setup.py
+++ b/setup.py
@@ -1,7 +1,7 @@
 import setuptools
 
 
-VERSION = '0.3'
+VERSION = '0.6'
 
 
 with open('README.md', 'r', encoding='utf-8') as fh: