diff --git a/target_redshift/__init__.py b/target_redshift/__init__.py index 82b31f0..bf3c6a8 100644 --- a/target_redshift/__init__.py +++ b/target_redshift/__init__.py @@ -13,7 +13,7 @@ from tempfile import mkstemp from joblib import Parallel, delayed, parallel_backend -from jsonschema import Draft4Validator, FormatChecker +from jsonschema import Draft7Validator, FormatChecker from singer import get_logger from itertools import islice @@ -204,7 +204,7 @@ def persist_lines(config, lines, table_cache=None) -> None: stream = o['stream'] schemas[stream] = float_to_decimal(o['schema']) - validators[stream] = Draft4Validator(schemas[stream], format_checker=FormatChecker()) + validators[stream] = Draft7Validator(schemas[stream], format_checker=FormatChecker()) # flush records from previous stream SCHEMA # if same stream has been encountered again, it means the schema might have been altered