Fix flake8 warnings

Author: MDUYN

investing_algorithm_framework/app/app.py

@@ -243,6 +243,8 @@ def initialize(self):
             portfolio_snap_service = self.container \
                 .portfolio_snapshot_service()
             market_cred_service = self.container.market_credential_service()
+            portfolio_provider_lookup = \
+                self.container.portfolio_provider_lookup()
             # Override the portfolio service with the backtest
             # portfolio service
             self.container.portfolio_service.override(
@@ -254,8 +256,7 @@ def initialize(self):
                     portfolio_repository=self.container.portfolio_repository(),
                     portfolio_configuration_service=portfolio_conf_service,
                     portfolio_snapshot_service=portfolio_snap_service,
-                    portfolio_provider_lookup=self.container\
-                        .portfolio_provider_lookup()
+                    portfolio_provider_lookup=portfolio_provider_lookup
                 )
             )
 
@@ -1080,7 +1081,8 @@ def _initialize_portfolios(self):
                 # Check if there are matching portfolio configurations
                 for portfolio in portfolios:
                     logger.info(
-                        f"Checking if there is an matching portfolio configuration "
+                        f"Checking if there is an matching portfolio "
+                        "configuration "
                         f"for portfolio {portfolio.identifier}"
                     )
                     portfolio_configuration = \
@@ -1094,7 +1096,7 @@ def _initialize_portfolios(self):
                             f"existing portfolio {portfolio.market}, "
                             f"please make sure that you have configured your "
                             f"app with the right portfolio configurations "
-                            f"for the existing portfolios." 
+                            f"for the existing portfolios."
                             f"If you want to create a new portfolio, please "
                             f"remove the existing database (WARNING!!: this "
                             f"will remove all existing history of your "
@@ -1118,8 +1120,8 @@ def _initialize_portfolios(self):
                         # Register a portfolio provider for the portfolio
                         portfolio_provider_lookup \
                             .register_portfolio_provider_for_market(
-                            portfolio_configuration.market
-                        )
+                                portfolio_configuration.market
+                            )
                         initial_balance = portfolio_configuration\
                             .initial_balance
 
@@ -1167,7 +1169,8 @@ def _initialize_portfolios(self):
                 if market_credential is None:
                     raise ImproperlyConfigured(
                         f"No market credential found for existing "
-                        f"portfolio {portfolio_configuration.market} with market "
+                        f"portfolio {portfolio_configuration.market} "
+                        "with market "
                         "Cannot initialize portfolio configuration."
                     )
 

investing_algorithm_framework/app/context.py

@@ -729,12 +729,12 @@ def close_position(
             )
 
         for order in self.order_service \
-            .get_all(
-                {
-                    "position": position.id,
-                    "status": OrderStatus.OPEN.value
-                }
-            ):
+                .get_all(
+                    {
+                        "position": position.id,
+                        "status": OrderStatus.OPEN.value
+                    }
+                ):
             self.order_service.cancel_order(order)
 
         target_symbol = position.get_symbol()
@@ -1150,7 +1150,9 @@ def count_trades(
 
         return self.trade_service.count(query_params)
 
-    def get_pending_trades(self, target_symbol=None, market=None) -> List[Trade]:
+    def get_pending_trades(
+            self, target_symbol=None, market=None
+    ) -> List[Trade]:
         """
         Function to get all pending trades. This function will return all
         pending trades that match the specified query parameters. If the
@@ -1164,7 +1166,8 @@ def get_pending_trades(self, target_symbol=None, market=None) -> List[Trade]:
             market: The market of the asset
 
         Returns:
-            List[Trade]: A list of pending trades that match the query parameters
+            List[Trade]: A list of pending trades that match
+                the query parameters
         """
         return self.trade_service.get_all(
             {

investing_algorithm_framework/dependency_container.py

@@ -14,6 +14,7 @@
     MarketCredentialService, TradeService, PortfolioSyncService, \
     OrderExecutorLookup, PortfolioProviderLookup
 
+
 def setup_dependency_container(app, modules=None, packages=None):
     app.container = DependencyContainer()
     app.container.wire(modules=modules, packages=packages)

investing_algorithm_framework/domain/models/trade/trade.py

@@ -1,5 +1,4 @@
 from dateutil.parser import parse
-from numpy.ma.core import filled
 
 from investing_algorithm_framework.domain.models.base_model import BaseModel
 from investing_algorithm_framework.domain.models.order import OrderSide, Order

investing_algorithm_framework/infrastructure/data_providers/__init__.py

@@ -1,5 +1,6 @@
 from .ccxt import CCXTDataProvider
 
+
 def get_default_data_providers():
     """
     Function to get the default data providers.
@@ -11,6 +12,7 @@ def get_default_data_providers():
         CCXTDataProvider(),
     ]
 
+
 __all__ = [
     'CCXTDataProvider',
     'get_default_data_providers',

investing_algorithm_framework/infrastructure/data_providers/csv.py

@@ -1,6 +1,5 @@
 import polars
 from datetime import datetime
-from typing import List
 from investing_algorithm_framework.domain import DataProvider, \
     TradingDataType, OperationalException
 
@@ -53,7 +52,7 @@ def has_data(
     ) -> bool:
 
         if symbol == self.symbol and market == self.market and \
-            data_type == self.data_type and time_frame == self.time_frame:
+                data_type == self.data_type and time_frame == self.time_frame:
             return True
 
         return False

investing_algorithm_framework/infrastructure/models/order/order_metadata.py

@@ -41,4 +41,4 @@ def __repr__(self):
         return f"<SQLOrderMetadata(id={self.id}, order_id={self.order_id}, " \
                f"trade_id={self.trade_id}, stop_loss_id={self.stop_loss_id}, "\
                f"take_profit_id={self.take_profit_id}, amount={self.amount}, "\
-               f"amount_pending={self.amount_pending})>"
+               f"amount_pending={self.amount_pending})>"

investing_algorithm_framework/infrastructure/order_executors/__init__.py

@@ -1,5 +1,6 @@
 from .ccxt_order_executor import CCXTOrderExecutor
 
+
 def get_default_order_executors():
     """
     Function to get the default order executors.
@@ -11,6 +12,7 @@ def get_default_order_executors():
         CCXTOrderExecutor(),
     ]
 
+
 __all__ = [
     'CCXTOrderExecutor',
     'get_default_order_executors',

investing_algorithm_framework/infrastructure/order_executors/ccxt_order_executor.py

@@ -39,7 +39,8 @@ def execute_order(self, portfolio, order, market_credential) -> Order:
             if OrderType.LIMIT.equals(order_type):
                 if OrderSide.BUY.equals(order_side):
 
-                    # Check if the exchange supports the createLimitBuyOrder method
+                    # Check if the exchange supports the
+                    # createLimitBuyOrder method
                     if not hasattr(exchange, "createLimitBuyOrder"):
                         raise OperationalException(
                             f"Exchange {market} does not support "
@@ -51,7 +52,8 @@ def execute_order(self, portfolio, order, market_credential) -> Order:
                         symbol, amount, price,
                     )
                 else:
-                    # Check if the exchange supports the createLimitSellOrder method
+                    # Check if the exchange supports
+                    # the createLimitSellOrder method
                     if not hasattr(exchange, "createLimitSellOrder"):
                         raise OperationalException(
                             f"Exchange {market} does not support "

investing_algorithm_framework/infrastructure/portfolio_providers/__init__.py

@@ -1,5 +1,6 @@
 from .ccxt_portfolio_provider import CCXTPortfolioProvider
 
+
 def get_default_portfolio_providers():
     """
     Function to get the default portfolio providers.