@@ -511,10 +511,14 @@ def join(
511511 # This check is to prevent breaking API changes where users prior to
512512 # DF 43.0.0 would pass the join_keys as a positional argument instead
513513 # of a keyword argument.
514- if isinstance (on , tuple ) and len (on ) == 2 :
515- if isinstance (on [0 ], list ) and isinstance (on [1 ], list ):
516- join_keys = on # type: ignore
517- on = None
514+ if (
515+ isinstance (on , tuple )
516+ and len (on ) == 2
517+ and isinstance (on [0 ], list )
518+ and isinstance (on [1 ], list )
519+ ):
520+ join_keys = on # type: ignore
521+ on = None
518522
519523 if join_keys is not None :
520524 warnings .warn (
@@ -723,9 +727,11 @@ def write_parquet(
723727 if isinstance (compression , str ):
724728 compression = Compression .from_str (compression )
725729
726- if compression in {Compression .GZIP , Compression .BROTLI , Compression .ZSTD }:
727- if compression_level is None :
728- compression_level = compression .get_default_level ()
730+ if (
731+ compression in {Compression .GZIP , Compression .BROTLI , Compression .ZSTD }
732+ and compression_level is None
733+ ):
734+ compression_level = compression .get_default_level ()
729735
730736 self .df .write_parquet (str (path ), compression .value , compression_level )
731737
0 commit comments