small refactor

ibis-project · Jun 27, 2024 · 4f03594 · 4f03594
1 parent fff1df5
commit 4f03594
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/ibis/backends/pyspark/__init__.py b/ibis/backends/pyspark/__init__.py
@@ -1165,16 +1165,14 @@ def _to_filesystem_output(
         df = self._session.sql(expr.compile())
         if self.mode == "batch":
             df = df.write.format(format)
-            if options is not None:
-                for k, v in options.items():
-                    df = df.option(k, v)
+            for k, v in (options or {}).items():
+                df = df.option(k, v)
             df.save(path)
             return None
         sq = df.writeStream.format(format)
         sq = sq.option("path", os.fspath(path))
-        if options is not None:
-            for k, v in options.items():
-                sq = sq.option(k, v)
+        for k, v in (options or {}).items():
+            sq = sq.option(k, v)
         sq.start()
         return sq