diff --git a/deltalake/deltatable.py b/deltalake/deltatable.py index ae7f04d..eaeb11e 100644 --- a/deltalake/deltatable.py +++ b/deltalake/deltatable.py @@ -126,8 +126,11 @@ def _apply_partial_logs(self, version: int): if remove_file in self.files: self.files.remove(remove_file) elif "metaData" in meta_data.keys(): - schema_string = meta_data["metaData"]["schemaString"] - self.schema = schema_from_string(schema_string) + try: + schema_string = meta_data["metaData"]["schemaString"] + self.schema = schema_from_string(schema_string) + except KeyError as e: + print(f"problematic record : {log_file},{e}") # Stop if we have reatched the desired version if self.version == version: break