fix: pylint

Author: jgaucher-cs

services/staging/rs_server_staging/main.py

@@ -52,7 +52,7 @@
 from . import jobs_table  # DON'T REMOVE (needed for SQLAlchemy)
 from .rspy_models import ProcessMetadataModel
 
-local_mode = env_bool("RSPY_LOCAL_MODE", default=False)
+LOCAL_MODE = env_bool("RSPY_LOCAL_MODE", default=False)
 
 logger = Logging.default(__name__)
 
@@ -211,7 +211,7 @@ async def app_lifespan(fastapi_app: FastAPI):  # pylint: disable=too-many-statem
 
     # In local mode, if the gateway is not defined, create a dask LocalCluster
     cluster = None
-    if local_mode and ("RSPY_DASK_STAGING_CLUSTER_NAME" not in os.environ):
+    if LOCAL_MODE and ("RSPY_DASK_STAGING_CLUSTER_NAME" not in os.environ):
         # Create the LocalCluster only in local mode
         cluster = LocalCluster()
         logger.info("Local Dask cluster created at startup.")
@@ -225,7 +225,7 @@ async def app_lifespan(fastapi_app: FastAPI):  # pylint: disable=too-many-statem
 
     # Shutdown logic (cleanup)
     logger.info("Shutting down the application...")
-    if local_mode and cluster:
+    if LOCAL_MODE and cluster:
         cluster.close()
         logger.info("Local Dask cluster shut down.")
 
@@ -328,7 +328,7 @@ async def get_specific_job_result_endpoint(job_id: str = Path(..., title="The ID
         raise HTTPException(status_code=HTTP_404_NOT_FOUND, detail=f"Job with ID {job_id} not found") from error
 
 
-if local_mode:
+if LOCAL_MODE:
 
     @router.post("/staging/dask/auth")
     async def dask_auth(local_dask_username: str, local_dask_password: str):

services/staging/rs_server_staging/processors.py

@@ -44,7 +44,7 @@
 
 from .rspy_models import Feature, FeatureCollectionModel
 
-local_mode = env_bool("RSPY_LOCAL_MODE", default=False)
+LOCAL_MODE = env_bool("RSPY_LOCAL_MODE", default=False)
 
 
 # Custom authentication class
@@ -619,7 +619,7 @@ def manage_dask_tasks_results(self, client: Client, catalog_collection: str):
         self.log_job_execution(JobStatus.successful, 100, "Finished")
         self.logger.info("Tasks monitoring finished")
 
-    def dask_cluster_connect(self) -> Client:
+    def dask_cluster_connect(self) -> Client:  # pylint: disable=too-many-branches,too-many-statements
         """Connects a dask cluster scheduler
         Establishes a connection to a Dask cluster, either in a local environment or via a Dask Gateway in
         a Kubernetes cluster. This method checks if the cluster is already created (for local mode) or connects
@@ -682,7 +682,7 @@ def dask_cluster_connect(self) -> Client:
                 cluster_name = os.environ["RSPY_DASK_STAGING_CLUSTER_NAME"]
 
                 # In local mode, authenticate to the dask cluster with username/password
-                if local_mode:
+                if LOCAL_MODE:
                     gateway_auth = BasicAuth(
                         os.environ["LOCAL_DASK_USERNAME"],
                         os.environ["LOCAL_DASK_PASSWORD"],
@@ -708,7 +708,7 @@ def dask_cluster_connect(self) -> Client:
 
                 # In local mode, get the first cluster from the gateway.
                 cluster_id = None
-                if local_mode:
+                if LOCAL_MODE:
                     if clusters:
                         cluster_id = clusters[0].name