fix: airbyte sources more resilient: ignore printed non airbyte messages

.gitignore

@@ -1,3 +1,4 @@
 __pycache__/
 airbyte_serverless.egg-info/
-dist/
+dist/
+TODO.md

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

setup.py

@@ -1,7 +1,7 @@
 import setuptools
 
 
-VERSION = '0.3'
+VERSION = '0.6'
 
 
 with open('README.md', 'r', encoding='utf-8') as fh: