Skip to content

Commit 5204206

Browse files
style: fix mypy error with entity.write
1 parent cfd4b20 commit 5204206

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/dve/core_engine/backends/implementations/spark/spark_helpers.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -357,7 +357,7 @@ def _spark_write_parquet( # pylint: disable=unused-argument
357357
_writer = self.spark_session.createDataFrame(entity).write
358358
else:
359359
_options["schema"] = entity.schema # type: ignore
360-
_writer = entity.write
360+
_writer = entity.write # type: ignore
361361

362362
(_writer.options(**_options).format("parquet").mode("overwrite").save(target_location))
363363
return target_location

0 commit comments

Comments
 (0)