fix: Remove unnecessary logging statements in DeltaLakeCallback

bmoscon · Sep 9, 2024 · cf0004a · cf0004a
1 parent 47ca6a4
commit cf0004a
Showing 1 changed file with 4 additions and 4 deletions.
diff --git 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)
-    """
+    """