flake8.

Author: maxim veksler

pandas/io/parquet.py

@@ -8,6 +8,7 @@
 from pandas.io.common import get_filepath_or_buffer
 from pandas.io.s3 import is_s3_url
 
+
 def get_engine(engine):
     """ return our implementation """
 
@@ -191,7 +192,7 @@ def __init__(self):
 
     def write(self, df, path, compression='snappy', **kwargs):
         if is_s3_url(path):
-            raise NotImplementedError("fastparquet s3 write is not implemented."
+            raise NotImplementedError("fastparquet s3 write isn't implemented."
                                       " Consider using pyarrow instead.")
 
         self.validate_dataframe(df)

pandas/tests/io/test_parquet.py

@@ -229,21 +229,26 @@ def check_round_trip(self, df, engine, expected=None, path=None,
             with tm.ensure_clean() as path:
                 df.to_parquet(path, engine, **write_kwargs)
                 actual = read_parquet(path, engine, **read_kwargs)
-                tm.assert_frame_equal(expected, actual, check_names=check_names)
+                tm.assert_frame_equal(expected, actual,
+                                      check_names=check_names)
 
                 # repeat
                 df.to_parquet(path, engine, **write_kwargs)
                 actual = read_parquet(path, engine, **read_kwargs)
-                tm.assert_frame_equal(expected, actual, check_names=check_names)
+                tm.assert_frame_equal(expected, actual,
+                                      check_names=check_names)
         else:
             df.to_parquet(path, engine, **write_kwargs)
             actual = read_parquet(path, engine, **read_kwargs)
-            tm.assert_frame_equal(expected, actual, check_names=check_names)
+            tm.assert_frame_equal(expected, actual,
+                                  check_names=check_names)
 
             # repeat
             df.to_parquet(path, engine, **write_kwargs)
             actual = read_parquet(path, engine, **read_kwargs)
-            tm.assert_frame_equal(expected, actual, check_names=check_names)
+            tm.assert_frame_equal(expected, actual,
+                                  check_names=check_names)
+
 
 class TestBasic(Base):
 
@@ -433,7 +438,8 @@ def test_categorical_unsupported(self, pa_lt_070):
 
     def test_s3_roundtrip(self, df_compat, s3_resource, pa):
         # GH #19134
-        self.check_round_trip(df_compat, pa, path='s3://pandas-test/pyarrow.parquet')
+        self.check_round_trip(df_compat, pa,
+                              path='s3://pandas-test/pyarrow.parquet')
 
 
 class TestParquetFastParquet(Base):
@@ -497,4 +503,5 @@ def test_filter_row_groups(self, fp):
     def test_s3_roundtrip(self, df_compat, s3_resource, fp):
         # GH #19134
         with pytest.raises(NotImplementedError):
-            self.check_round_trip(df_compat, fp, path='s3://pandas-test/fastparquet.parquet')
+            self.check_round_trip(df_compat, fp,
+                                  path='s3://pandas-test/fastparquet.parquet')

pandas/tests/io/test_s3.py

@@ -6,4 +6,3 @@ class TestS3URL(object):
     def test_is_s3_url(self):
         assert is_s3_url("s3://pandas/somethingelse.com")
         assert not is_s3_url("s4://pandas/somethingelse.com")
-