66
77LOGGER = get_logger ()
88
9+
910def write_state (state ):
1011 json .dump (state .to_dict (), sys .stdout , indent = 2 )
1112
13+
1214class State :
1315 def __init__ (
14- self , bookmarks : Optional [Dict ] = None , currently_syncing : Optional [str ] = None
16+ self , bookmarks : Optional [Dict ] = None , currently_syncing : Optional [str ] = None # pylint: disable=bad-continuation
1517 ) -> None :
1618 self ._bookmarks = bookmarks or {}
1719 self ._currently_syncing = currently_syncing
@@ -71,7 +73,7 @@ def get_bookmark(self, tap_stream_id: str, key: str, default: Any = None) -> Any
7173 return self .bookmarks .get (tap_stream_id , {}).get (key , default )
7274
7375 def set_offset (
74- self , tap_stream_id : str , offset_key : str , offset_value : Any
76+ self , tap_stream_id : str , offset_key : str , offset_value : Any # pylint: disable=bad-continuation
7577 ) -> None :
7678 self ._ensure_bookmark_path ((tap_stream_id , "offset" , offset_key ))
7779 self .bookmarks [tap_stream_id ]["offset" ][offset_key ] = offset_value
@@ -81,7 +83,7 @@ def clear_offset(self, tap_stream_id: str) -> None:
8183 self .bookmarks [tap_stream_id ]["offset" ] = {}
8284
8385 def get_offset (
84- self , tap_stream_id : str , offset_key : str , default : Any = None
86+ self , tap_stream_id : str , offset_key : str , default : Any = None # pylint: disable=bad-continuation
8587 ) -> Any :
8688 return (
8789 self .bookmarks .get (tap_stream_id , {})
0 commit comments