update

Author: cloudQuant

bt_api_py/configs/binance_spot_symbol_info.pkl

@@ -105,7 +105,7 @@ def _parse_single_bar(self, bar_data: Any) -> "GeminiRequestBarData | None":
         """
         if len(bar_data) >= 6:
             bar = GeminiRequestBarData(
-                data=bar_data,
+                data=None,
                 symbol=self.symbol,
                 asset_type=self.asset_type,
                 time_frame=self.time_frame,

bt_api_py/configs/binance_swap_symbol_info.pkl

@@ -205,13 +205,13 @@ def init_data(self):
             data = self.bar_data["data"]
             candles = data.get("candles", [])
             if candles:
-                self.server_time = from_dict_get_float(candles, 0) * 1000
-                self.open = from_dict_get_float(candles, 1)
-                self.close = from_dict_get_float(candles, 2)
-                self.high = from_dict_get_float(candles, 3)
-                self.low = from_dict_get_float(candles, 4)
-                self.volume = from_dict_get_float(candles, 5)
-                self.turnover = from_dict_get_float(candles, 6)
+                self.server_time = float(candles[0]) * 1000
+                self.open = float(candles[1])
+                self.close = float(candles[2])
+                self.high = float(candles[3])
+                self.low = float(candles[4])
+                self.volume = float(candles[5])
+                self.turnover = float(candles[6]) if len(candles) > 6 else 0.0
             self.bar_symbol_name = from_dict_get_string(data, "symbol")
 
         self.period = None  # Could extract from topic string

bt_api_py/containers/bars/gemini_bar.py

@@ -244,7 +244,7 @@ def _server_loop(self) -> None:
                 # Handle server shutdown gracefully
                 break
             except Exception as e:
-                _logger.debug("Prometheus server loop error, continuing: %s", e, exc_info=True)
+                _logger.debug(f"Prometheus server loop error, continuing: {e}")
                 continue
 
     def is_running(self) -> bool:

bt_api_py/containers/bars/kucoin_bar.py

@@ -45,6 +45,7 @@ Repository = "https://github.com/cloudQuant/bt_api_py"
 [tool.pytest.ini_options]
 addopts = [
     "--dist=loadgroup",
+    "--import-mode=importlib",
     "--strict-markers",
     "--tb=short",
 ]

bt_api_py/monitoring/prometheus.py

@@ -97,9 +97,11 @@ def run_coverage_analysis(self) -> dict:
             finally:
                 os.chdir(previous_cwd)
 
-            if result == 0 and coverage_json.exists():
+            if coverage_json.exists():
                 with coverage_json.open() as f:
                     coverage_data = json.load(f)
+                if result != 0:
+                    print(f"Pytest exited with status {result}, using partial coverage data")
                 return coverage_data
         except Exception as e:
             print(f"Error running coverage: {e}")

coverage.json

@@ -7,4 +7,4 @@
 - Shared test utilities and hooks
 """
 
-pytest_plugins = ["conftest_test_data"]
+pytest_plugins = ["tests.conftest_test_data"]