We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent cfd4b20 commit 5204206Copy full SHA for 5204206
1 file changed
src/dve/core_engine/backends/implementations/spark/spark_helpers.py
@@ -357,7 +357,7 @@ def _spark_write_parquet( # pylint: disable=unused-argument
357
_writer = self.spark_session.createDataFrame(entity).write
358
else:
359
_options["schema"] = entity.schema # type: ignore
360
- _writer = entity.write
+ _writer = entity.write # type: ignore
361
362
(_writer.options(**_options).format("parquet").mode("overwrite").save(target_location))
363
return target_location
0 commit comments