fix: Convert integer columns in DeltaLakeCallback

cryptofeed/backends/deltalake.py

@@ -221,6 +221,7 @@ def _convert_datetime_columns(self, df: pd.DataFrame):
             LOG.debug(f"Sample 'dt' value: {df['dt'].iloc[0]}")
 
         LOG.debug("Datetime columns converted and 'dt' column created.")
+
     def _convert_int_columns(self, df: pd.DataFrame):
         LOG.debug("Converting integer columns.")
         int_columns = ["id", "trade_id", "trades"]

examples/demo_deltalake.py

@@ -12,7 +12,7 @@
 
 def main():
     f = FeedHandler()
-    
+
     # Define the Delta Lake base path (can be local or S3)
     delta_base_path = 's3://your-bucket/path/to/delta/tables'
 
@@ -53,9 +53,9 @@ def main():
             )
         }
     ))
-    
+
     f.run()
 
 
 if __name__ == '__main__':
-    main()
+    main()

setup.py

@@ -1,9 +1,9 @@
-'''
+"""
 Copyright (C) 2017-2024 Bryant Moscon - [email protected]
 
 Please see the LICENSE file for the terms and conditions
 associated with this software.
-'''
+"""
 import os
 import sys