diff --git a/target_s3/formats/format_jsonl.py b/target_s3/formats/format_jsonl.py index d324a21..f0fe5b9 100644 --- a/target_s3/formats/format_jsonl.py +++ b/target_s3/formats/format_jsonl.py @@ -26,7 +26,11 @@ def _prepare_records(self): return super()._prepare_records() def _write(self) -> None: - return super()._write('\n'.join(map(dumps, self.records))) + return super()._write( + "\n".join( + map(lambda record: dumps(record, cls=JsonSerialize), self.records) + ) + ) def run(self) -> None: # use default behavior, no additional run steps needed