diff --git a/cryptofeed/backends/deltalake.py b/cryptofeed/backends/deltalake.py index 0022e9b98..fea97730f 100644 --- a/cryptofeed/backends/deltalake.py +++ b/cryptofeed/backends/deltalake.py @@ -300,9 +300,9 @@ async def _write_batch(self, df: pd.DataFrame): ) # Logging statements just before write_deltalake - sample_size = min(5, len(df)) # Show up to 5 rows - LOG.debug(f"Sample of DataFrame to be written (first {sample_size} rows):") - LOG.debug(df.head(sample_size).to_string()) + # sample_size = min(5, len(df)) # Show up to 5 rows + # LOG.debug(f"Sample of DataFrame to be written (first {sample_size} rows):") + # LOG.debug(df.head(sample_size).to_string()) LOG.debug("DataFrame dtypes:") LOG.debug(df.dtypes.to_string()) LOG.warning(f"Writing batch of {len(df)} records to {self.delta_table_path}") @@ -564,4 +564,4 @@ class FillsDeltaLake(DeltaLakeCallback, BackendCallback): - liquidity: category - type: category - account: string (nullable) - """ \ No newline at end of file + """