fix other bug

danielgafni · Oct 25, 2023 · 12b30b4 · 12b30b4
1 parent 89c1e6c
commit 12b30b4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dagster_polars/io_managers/delta.py b/dagster_polars/io_managers/delta.py
@@ -54,7 +54,7 @@ def dump_df_to_path(self, context: OutputContext, df: pl.DataFrame, path: UPath)
 
         df.write_delta(
             str(path),
-            mode=self.mode or context.metadata.get("mode"),  # type: ignore
+            mode=context.metadata.get("mode") or self.mode,  # type: ignore
             overwrite_schema=self.overwrite_schema or bool(context.metadata.get("overwrite_schema", False)),
             storage_options=storage_options,
             delta_write_options=delta_write_options,