Lint fixes for RUF013 and FA100 errors (#309)

Author: IgorChvyrov-sm

.pre-commit-config.yaml

@@ -3,4 +3,4 @@ repos:
     rev: v0.12.3
     hooks:
       - id: ruff
-        args: [""]
+        args: ["--exit-zero"]

src/conductor/client/ai/integrations.py

@@ -2,7 +2,7 @@
 
 import os
 from abc import ABC, abstractmethod
-
+from typing import Optional
 
 class IntegrationConfig(ABC):
     def __init__(self):
@@ -29,7 +29,7 @@ def to_dict(self) -> dict:
 
 class OpenAIConfig(IntegrationConfig):
 
-    def __init__(self, api_key: str = None) -> None:
+    def __init__(self, api_key: Optional[str] = None) -> None:
         if api_key is None:
             api_key = os.getenv('OPENAI_API_KEY')
         self.api_key = api_key
@@ -55,7 +55,7 @@ def to_dict(self) -> dict:
 
 class PineconeConfig(IntegrationConfig):
 
-    def __init__(self, api_key: str = None, endpoint: str = None, environment: str = None, project_name: str = None) -> None:
+    def __init__(self, api_key: Optional[str] = None, endpoint: Optional[str] = None, environment: Optional[str] = None, project_name: Optional[str] = None) -> None:
         if api_key is None:
             self.api_key = os.getenv('PINECONE_API_KEY')
         else:

src/conductor/client/ai/orchestrator.py

@@ -73,8 +73,8 @@ def add_ai_integration(self, ai_integration_name: str, provider: LLMProvider, mo
             if existing_integration_api is None or overwrite:
                 self.integration_client.save_integration_api(ai_integration_name, model, api_details)
 
-    def add_vector_store(self, db_integration_name: str, provider: VectorDB, indices: List[str],config: IntegrationConfig,
-                         description: str = None,overwrite : bool = False):
+    def add_vector_store(self, db_integration_name: str, provider: VectorDB, indices: List[str], config: IntegrationConfig,
+                         description: Optional[str] = None, overwrite: bool = False):
         vector_db = IntegrationUpdate()
         vector_db.configuration = config.to_dict()
         vector_db.type = provider.value

src/conductor/client/authorization_client.py

@@ -1,3 +1,4 @@
+from __future__ import annotations
 from abc import ABC, abstractmethod
 from typing import Dict, List, Optional
 from conductor.client.orkes.models.metadata_tag import MetadataTag

src/conductor/client/automator/task_handler.py

@@ -1,9 +1,10 @@
+from __future__ import annotations
 import importlib
 import logging
 import os
 from multiprocessing import Process, freeze_support, Queue, set_start_method, get_context
 from sys import platform
-from typing import List
+from typing import List, Optional
 
 from conductor.client.automator.task_runner import TaskRunner
 from conductor.client.configuration.configuration import Configuration
@@ -46,10 +47,10 @@ class TaskHandler:
     def __init__(
             self,
             workers: List[WorkerInterface] = [],
-            configuration: Configuration = None,
-            metrics_settings: MetricsSettings = None,
+            configuration: Optional[Configuration] = None,
+            metrics_settings: Optional[MetricsSettings] = None,
             scan_for_annotated_workers: bool = True,
-            import_modules: List[str] = None
+            import_modules: Optional[List[str]] = None
     ):
         self.logger_process, self.queue = _setup_logging_queue(configuration)
 

src/conductor/client/automator/utils.py

@@ -1,3 +1,4 @@
+from __future__ import annotations
 import dataclasses
 import datetime
 import inspect

src/conductor/client/configuration/configuration.py

@@ -1,6 +1,8 @@
+from __future__ import annotations
 import logging
 import os
 import time
+from typing import Optional
 
 from conductor.client.configuration.settings.authentication_settings import AuthenticationSettings
 
@@ -10,10 +12,10 @@ class Configuration:
 
     def __init__(
             self,
-            base_url: str = None,
+            base_url: Optional[str] = None,
             debug: bool = False,
             authentication_settings: AuthenticationSettings = None,
-            server_api_url: str = None,
+            server_api_url: Optional[str] = None,
             auth_token_ttl_min: int = 45
     ):
         if server_api_url is not None:
@@ -138,7 +140,7 @@ def ui_host(self):
         """
         return self.__ui_host
 
-    def apply_logging_config(self, log_format : str = None, level = None):
+    def apply_logging_config(self, log_format : Optional[str] = None, level = None):
         if log_format is None:
             log_format = self.logger_format
         if level is None:

src/conductor/client/configuration/settings/metrics_settings.py

@@ -1,5 +1,7 @@
+from __future__ import annotations
 import logging
 import os
+from typing import Optional
 from pathlib import Path
 
 from conductor.client.configuration.configuration import Configuration
@@ -18,7 +20,7 @@ def get_default_temporary_folder() -> str:
 class MetricsSettings:
     def __init__(
             self,
-            directory: str = None,
+            directory: Optional[str] = None,
             file_name: str = 'metrics.log',
             update_interval: float = 0.1):
         if directory is None:

src/conductor/client/metadata_client.py

@@ -1,3 +1,4 @@
+from __future__ import annotations
 from abc import ABC, abstractmethod
 from typing import Optional, List
 from conductor.client.http.models.workflow_def import WorkflowDef

src/conductor/client/orkes/orkes_authorization_client.py

@@ -1,3 +1,4 @@
+from __future__ import annotations
 from typing import Dict, List, Optional
 
 from conductor.client.authorization_client import AuthorizationClient