Better error avoidance (#32)

* include parsing state_file in try block
* bump version

setup.py

@@ -6,7 +6,7 @@
       long_description = f.read()
 
 setup(name='pipelinewise-tap-postgres',
-      version='1.2.0',
+      version='1.2.1',
       description='Singer.io tap for extracting data from PostgreSQL - PipelineWise compatible',
       long_description=long_description,
       long_description_content_type='text/markdown',

tap_postgres/sync_strategies/logical_replication.py

@@ -466,10 +466,9 @@ def sync_tables(conn_info, logical_streams, state, end_lsn, state_file):
                 LOGGER.info("{} : Last wal message received was {} at {}".format(datetime.datetime.utcnow(), int_to_lsn(lsn_last_processed), lsn_received_timestamp))
                 try:
                     state_comitted_file = open(state_file)
-                except:
-                    LOGGER.warning("{} : Unable to open {}".format(datetime.datetime.utcnow(), state_file))
-                else:
                     state_comitted = json.load(state_comitted_file)
+                except:
+                    LOGGER.warning("{} : Unable to open and parse {}".format(datetime.datetime.utcnow(), state_file))
                 finally:
                     lsn_comitted = min([get_bookmark(state_comitted, s['tap_stream_id'], 'lsn') for s in logical_streams])
                     lsn_to_flush = lsn_comitted