[ISSUE #19733] fix linting error

airbytehq · Dec 2, 2022 · 3c16721 · 3c16721
1 parent 0623bbb
commit 3c16721
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/airbyte-cdk/python/airbyte_cdk/sources/source.py b/airbyte-cdk/python/airbyte_cdk/sources/source.py
@@ -3,7 +3,6 @@
 #
 
 
-import json
 import logging
 from abc import ABC, abstractmethod
 from collections import defaultdict
@@ -54,7 +53,7 @@ def read_state(self, state_path: str) -> Union[List[AirbyteStateMessage], Mutabl
         :return: The complete stream state based on the connector's previous sync
         """
         if state_path:
-            state_obj = json.loads(open(state_path, "r").read())
+            state_obj = self.read_json_file(state_path)
             if not state_obj:
                 return self._emit_legacy_state_format({})
             is_per_stream_state = isinstance(state_obj, List)