@@ -202,11 +202,19 @@ def get_table_column_names_and_types(
                 "AWS_ENDPOINT_URL": str(self.s3_endpoint_override),
             }
 
-            schema = (
+            delta_schema = (
                 DeltaTable(self.path, storage_options=storage_options)
                 .schema()
-                .to_pyarrow()
             )
+            if hasattr(delta_schema, "to_arrow"):
+                # deltalake >= 0.10.0
+                arro3_schema = delta_schema.to_arrow()
+                schema = pyarrow.schema(arro3_schema)
+            elif hasattr(delta_schema, "to_pyarrow"):
+                # deltalake < 0.10.0
+                schema = delta_schema.to_pyarrow()
+            else:
+                raise Exception(f"Unknown DeltaTable package version")
         else:
             raise Exception(f"Unknown FileFormat -> {self.file_format}")