Fix flake8 warnings

Author: MDUYN

investing_algorithm_framework/app/app.py

@@ -529,12 +529,12 @@ def run(
                 # Upload state if state handler is provided
                 if self._state_handler is not None:
                     logger.info("Detected state handler, saving state")
-                    config = self.container.configuration_service().get_config()
+                    config = \
+                        self.container.configuration_service().get_config()
                     self._state_handler.save(config[RESOURCE_DIRECTORY])
             except Exception as e:
                 logger.error(e)
 
-
     def reset(self):
         self._started = False
         self.algorithm.reset()

investing_algorithm_framework/cli/cli.py

@@ -7,7 +7,8 @@
 """
 CLI for Investing Algorithm Framework
 
-This module provides a command-line interface (CLI) for the Investing Algorithm Framework.
+This module provides a command-line interface (CLI) for the
+Investing Algorithm Framework.
 """
 
 
@@ -16,11 +17,13 @@ def cli():
     """CLI for Investing Algorithm Framework"""
     pass
 
+
 @click.command()
 @click.option(
     '--type',
     default="default",
-    help="Type of app to create. Options are: 'default', 'default-web', 'azure-function'."
+    help="Type of app to create. "
+    "Options are: 'default', 'default-web', 'azure-function'."
 )
 @click.option(
     '--path', default=None, help="Path to directory to initialize the app in"
@@ -29,7 +32,8 @@ def cli():
     '--replace',
     is_flag=True,
     default=False,
-    help="If True, duplicate files will be replaced. If False, files will not be replaced."
+    help="If True, duplicate files will be replaced."
+    "If False, files will not be replaced."
 )
 def init(type, path, replace):
     """
@@ -128,17 +132,18 @@ def deploy_azure_function(
     Returns:
         None
     """
+    crg = create_resource_group_if_not_exists
     deploy_to_azure_function_command(
         resource_group=resource_group,
         subscription_id=subscription_id,
         storage_account_name=storage_account_name,
         container_name=container_name,
         deployment_name=deployment_name,
         region=region,
-        create_resource_group_if_not_exists=\
-            create_resource_group_if_not_exists,
+        create_resource_group_if_not_exists=crg,
         skip_login=skip_login
     )
 
+
 cli.add_command(init)
 cli.add_command(deploy_azure_function)

investing_algorithm_framework/cli/deploy_to_azure_function.py

@@ -5,7 +5,6 @@
 import string
 import asyncio
 import time
-import requests
 
 from azure.identity import DefaultAzureCredential
 from azure.mgmt.resource import ResourceManagementClient
@@ -52,6 +51,7 @@ def ensure_azure_functools():
         print("npm install -g azure-functions-core-tools@4 --unsafe-perm true")
         exit(1)
 
+
 async def read_env_file_and_set_function_env_variables(
     function_app_name,
     storage_connection_string,

investing_algorithm_framework/cli/initialize_app.py

@@ -99,7 +99,7 @@ def create_file_from_template(template_path, output_path, replace=False):
             file.write(template)
 
 
-def command(path = None, app_type = "default", replace = False):
+def command(path=None, app_type="default", replace=False):
     """
     Function to create an azure function app skeleton.
 
@@ -115,7 +115,7 @@ def command(path = None, app_type = "default", replace = False):
         None
     """
 
-    if path == None:
+    if path is None:
         path = os.getcwd()
     else:
         # check if directory exists

investing_algorithm_framework/infrastructure/services/azure/state_handler.py

@@ -12,7 +12,8 @@ class AzureBlobStorageStateHandler(StateHandler):
     """
     A state handler for Azure Blob Storage.
 
-    This class provides methods to save and load state to and from Azure Blob Storage.
+    This class provides methods to save and load state to and from
+    Azure Blob Storage.
 
     Attributes:
         connection_string (str): The connection string for Azure Blob Storage.

investing_algorithm_framework/infrastructure/services/market_service/ccxt_market_service.py

@@ -421,7 +421,10 @@ def get_ohlcv(
                     datetime_stamp = datetime_stamp\
                         .strftime(datetime_format)
 
-                    data.append([datetime_stamp] + [float(value) for value in candle[1:]])
+                    data.append(
+                        [datetime_stamp] +
+                        [float(value) for value in candle[1:]]
+                    )
 
             sleep(exchange.rateLimit / 1000)