fix: resolve all 39 ruff linting errors

Author: cloudQuant

backtrader/analyzer.py

@@ -35,7 +35,7 @@
 from collections import OrderedDict
 
 from .dataseries import TimeFrame
-from .metabase import findowner, OwnerContext
+from .metabase import findowner
 from .observer import Observer
 from .parameters import ParameterizedBase
 from .strategy import Strategy
@@ -108,12 +108,12 @@ class Analyzer(ParameterizedBase):
     def __init__(self, *args, **kwargs):
         """
         Initialize Analyzer with basic functionality.
-        
+
         Note: __new__ removed - _children initialization moved here.
         """
         # Initialize children list (moved from __new__)
         self._children = list()
-        
+
         # Initialize parent first
         super().__init__(*args, **kwargs)
 
@@ -572,7 +572,8 @@ def _get_subday_cmpkey(self, dt):
         tadjust = datetime.timedelta(
             minutes=self.timeframe == TimeFrame.Minutes,
             seconds=self.timeframe == TimeFrame.Seconds,
-            microseconds=self.timeframe == TimeFrame.MicroSeconds)
+            microseconds=self.timeframe == TimeFrame.MicroSeconds,
+        )
 
         # Add extra day if present
         # If next day is True, adjust time to next day

backtrader/analyzers/logreturnsrolling.py

@@ -118,9 +118,7 @@ def start(self):
             self._fundmode = self.p.fund
         # The special part is that self._values is set as a queue, where self.compression parameter controls how many elements the queue saves
         # Note: use self.compression (set in _start from data) not self.p.compression (which may be None)
-        self._values = collections.deque(
-            [float("Nan")] * self.compression, maxlen=self.compression
-        )
+        self._values = collections.deque([float("Nan")] * self.compression, maxlen=self.compression)
 
         if self.p.data is None:
             # keep the initial portfolio value if not tracing data

backtrader/analyzers/sharpe_ratio_stats.py

@@ -12,6 +12,7 @@
     min_track_record_length: Minimum track record for significance.
     sharpe_ratio_defacto: Defacto Sharpe ratio calculation.
 """
+
 import numpy as np
 import pandas as pd
 from scipy import stats as scipy_stats

backtrader/analyzers/total_value.py

@@ -12,6 +12,7 @@
     >>> results = cerebro.run()
     >>> print(results[0].analyzers.val.get_analysis())
 """
+
 from collections import OrderedDict
 
 from ..analyzer import Analyzer

backtrader/bokeh/__init__.py

@@ -1,5 +1,4 @@
 #!/usr/bin/env python
-# -*- coding: utf-8; py-indent-offset:4 -*-
 """
 Backtrader Bokeh Module
 
@@ -13,22 +12,22 @@
 Example:
     import backtrader as bt
     from backtrader.bokeh import LivePlotAnalyzer, Blackly
-    
+
     cerebro = bt.Cerebro()
     cerebro.adddata(data)
     cerebro.addstrategy(MyStrategy)
-    
+
     # Add live plot analyzer
     cerebro.addanalyzer(LivePlotAnalyzer,
                        scheme=Blackly(),
                        lookback=100)
-    
+
     cerebro.run()
 """
 
-from .schemes import Scheme, Blackly, Tradimo
-from .tab import BokehTab
 from . import tabs
+from .schemes import Blackly, Scheme, Tradimo
+from .tab import BokehTab
 from .utils import get_datanames, get_strategy_label, sanitize_source_name
 
 # Custom tab registry
@@ -37,7 +36,7 @@
 
 def register_tab(tab_class):
     """Register a custom tab.
-    
+
     Args:
         tab_class: Tab class that inherits from BokehTab
     """
@@ -54,39 +53,44 @@ def get_registered_tabs():
 # Lazy import to avoid circular dependencies
 def __getattr__(name):
     """Lazy load module attributes."""
-    if name == 'BacktraderBokeh':
+    if name == "BacktraderBokeh":
         from .app import BacktraderBokeh
+
         return BacktraderBokeh
-    elif name == 'LivePlotAnalyzer':
+    elif name == "LivePlotAnalyzer":
         from .analyzers import LivePlotAnalyzer
+
         return LivePlotAnalyzer
-    elif name == 'RecorderAnalyzer':
+    elif name == "RecorderAnalyzer":
         from .analyzers import RecorderAnalyzer
+
         return RecorderAnalyzer
-    elif name == 'LiveClient':
+    elif name == "LiveClient":
         from .live import LiveClient
+
         return LiveClient
-    elif name == 'LiveDataHandler':
+    elif name == "LiveDataHandler":
         from .live import LiveDataHandler
+
         return LiveDataHandler
-    
+
     raise AttributeError(f"module {__name__!r} has no attribute {name!r}")
 
 
 __all__ = [
-    'BacktraderBokeh',
-    'Scheme',
-    'Blackly',
-    'Tradimo',
-    'BokehTab',
-    'LivePlotAnalyzer',
-    'RecorderAnalyzer',
-    'LiveClient',
-    'LiveDataHandler',
-    'tabs',
-    'register_tab',
-    'get_registered_tabs',
-    'get_datanames',
-    'get_strategy_label',
-    'sanitize_source_name',
+    "BacktraderBokeh",
+    "Scheme",
+    "Blackly",
+    "Tradimo",
+    "BokehTab",
+    "LivePlotAnalyzer",
+    "RecorderAnalyzer",
+    "LiveClient",
+    "LiveDataHandler",
+    "tabs",
+    "register_tab",
+    "get_registered_tabs",
+    "get_datanames",
+    "get_strategy_label",
+    "sanitize_source_name",
 ]

backtrader/bokeh/analyzers/__init__.py

@@ -1,5 +1,4 @@
 #!/usr/bin/env python
-# -*- coding: utf-8; py-indent-offset:4 -*-
 """
 Bokeh analyzers module.
 
@@ -11,4 +10,4 @@
 from .plot import LivePlotAnalyzer
 from .recorder import RecorderAnalyzer
 
-__all__ = ['LivePlotAnalyzer', 'RecorderAnalyzer']
+__all__ = ["LivePlotAnalyzer", "RecorderAnalyzer"]

backtrader/bokeh/analyzers/plot.py

@@ -1,5 +1,4 @@
 #!/usr/bin/env python
-# -*- coding: utf-8; py-indent-offset:4 -*-
 """
 Live plotting analyzer.
 
@@ -13,16 +12,17 @@
 
 try:
     import tornado.ioloop
+
     TORNADO_AVAILABLE = True
 except ImportError:
     TORNADO_AVAILABLE = False
 
 import backtrader as bt
 
 from ..app import BacktraderBokeh
-from ..webapp import Webapp
-from ..schemes import Tradimo, Blackly
 from ..live.client import LiveClient
+from ..schemes import Tradimo
+from ..webapp import Webapp
 
 _logger = logging.getLogger(__name__)
 
@@ -51,15 +51,15 @@ class LivePlotAnalyzer(bt.Analyzer):
                           lookback=100,
                           port=8999)
     """
-    
+
     params = (
-        ('scheme', None),           # Theme
-        ('style', 'bar'),           # Chart style
-        ('lookback', 100),          # Historical data retention
-        ('address', 'localhost'),   # Server address
-        ('port', 8999),             # Server port
-        ('title', None),            # Title
-        ('autostart', True),        # Auto-start
+        ("scheme", None),  # Theme
+        ("style", "bar"),  # Chart style
+        ("lookback", 100),  # Historical data retention
+        ("address", "localhost"),  # Server address
+        ("port", 8999),  # Server port
+        ("title", None),  # Title
+        ("autostart", True),  # Auto-start
     )
 
     def __init__(self, **kwargs):
@@ -76,48 +76,46 @@ def __init__(self, **kwargs):
                 - autostart: Whether to auto-start server (default: True)
         """
         super().__init__()
-        
+
         # Set title
         title = self.p.title
         if title is None:
-            title = f'Live {type(self.strategy).__name__}'
-        
+            title = f"Live {type(self.strategy).__name__}"
+
         # Set auto-start
-        autostart = kwargs.get('autostart', self.p.autostart)
-        
+        autostart = kwargs.get("autostart", self.p.autostart)
+
         # Get theme
         scheme = self.p.scheme
         if scheme is None:
             scheme = Tradimo()
-        
+
         # Create Webapp
         self._webapp = Webapp(
             title=title,
-            template='basic.html.j2',
+            template="basic.html.j2",
             scheme=scheme,
             on_root_model=self._app_cb_build_root_model,
             on_session_destroyed=self._on_session_destroyed,
             autostart=autostart,
             address=self.p.address,
-            port=self.p.port
+            port=self.p.port,
         )
-        
+
         self._lock = Lock()
         self._clients = {}
         self._app_kwargs = kwargs
-    
+
     def _create_app(self):
         """Create BacktraderBokeh application instance.
 
         Returns:
             BacktraderBokeh instance
         """
         return BacktraderBokeh(
-            style=self.p.style,
-            scheme=self.p.scheme or Tradimo(),
-            **self._app_kwargs
+            style=self.p.style, scheme=self.p.scheme or Tradimo(), **self._app_kwargs
         )
-    
+
     def _on_session_destroyed(self, session_context):
         """Session destroyed callback.
 
@@ -129,17 +127,17 @@ def _on_session_destroyed(self, session_context):
             if session_id in self._clients:
                 self._clients[session_id].stop()
                 del self._clients[session_id]
-    
+
     def _t_server(self):
         """Server thread method."""
         if not TORNADO_AVAILABLE:
-            _logger.error('Tornado is not available. Cannot start Bokeh server.')
+            _logger.error("Tornado is not available. Cannot start Bokeh server.")
             return
-        
+
         asyncio.set_event_loop(asyncio.new_event_loop())
         loop = tornado.ioloop.IOLoop.current()
         self._webapp.start(loop)
-    
+
     def _app_cb_build_root_model(self, doc):
         """Build root model callback.
 
@@ -149,37 +147,32 @@ def _app_cb_build_root_model(self, doc):
         Returns:
             Root model
         """
-        client = LiveClient(
-            doc,
-            self._create_app(),
-            self.strategy,
-            self.p.lookback
-        )
-        
+        client = LiveClient(doc, self._create_app(), self.strategy, self.p.lookback)
+
         with self._lock:
             self._clients[doc.session_context.id] = client
-        
+
         return client.model
-    
+
     def start(self):
         """Start from backtrader.
 
         Starts the Bokeh Server.
         """
-        _logger.debug('Starting LivePlotAnalyzer...')
-        
+        _logger.debug("Starting LivePlotAnalyzer...")
+
         t = threading.Thread(target=self._t_server)
         t.daemon = True
         t.start()
-    
+
     def stop(self):
         """Stop from backtrader."""
-        _logger.debug('Stopping LivePlotAnalyzer...')
-        
+        _logger.debug("Stopping LivePlotAnalyzer...")
+
         with self._lock:
             for client in self._clients.values():
                 client.stop()
-    
+
     def next(self):
         """Receive new data from backtrader.
 
@@ -188,7 +181,7 @@ def next(self):
         with self._lock:
             for client in self._clients.values():
                 client.next()
-    
+
     def get_analysis(self):
         """Return analysis results.