WIP tests

Author: kinow

CHANGELOG.md

@@ -3,7 +3,6 @@
 **Bug fixes:**
 
 - Fixed issue with the verification of dirty Git local repositories in operational experiments #2446
-- Fixed issue where Autosubmit did not retry when there were networking issues in platforms #1369
 
 **Enhancements:**
 

autosubmit/database/db_manager.py

@@ -35,9 +35,9 @@ def __init__(self, root_path: str, db_name: str, db_version: int):
         if is_new:
             self._initialize_database()
     def backup(self):
-        pass
+        pass  # pragma: no cover
     def restore(self):
-        pass
+        pass  # pragma: no cover
 
     def disconnect(self):
         """

autosubmit/history/platform_monitor/platform_utils.py

@@ -49,7 +49,6 @@ def parse_output_number(string_number):
             number = float(number) * multiplier
         except Exception:
             number = 0.0
-            pass        
     return number
 
 def try_parse_time_to_timestamp(input_):

autosubmit/history/strategies.py

@@ -40,14 +40,14 @@ def execute_distribution(self, job_data_dc, job_data_dcs_in_wrapper, slurm_monit
 
 
 class Strategy(metaclass=ABCMeta):
-  """ Strategy Interface """
+  """Strategy Interface"""
 
   def __init__(self, historiclog_dir_path=DEFAULT_HISTORICAL_LOGS_DIR):
     self.historiclog_dir_path = historiclog_dir_path
 
   @abstractmethod
   def apply_distribution(self, job_data_dc, job_data_dcs_in_wrapper, slurm_monitor):
-    pass
+    pass  # pragma: no cover
 
   def set_job_data_dc_as_processed(self, job_data_dc, original_ssh_output):
     job_data_dc.platform_output = original_ssh_output

autosubmit/job/job_list.py

@@ -1763,7 +1763,7 @@ def get_date_format(self):
         return date_format
 
     def copy_ordered_jobs_by_date_member(self):
-        pass
+        pass  # pragma: no cover
 
     def get_ordered_jobs_by_date_member(self, section):
         """

autosubmit/job/job_list_persistence.py

@@ -42,7 +42,7 @@ def save(self, persistence_path, persistence_file, job_list , graph):
         :param persistence_path: str
 
         """
-        raise NotImplementedError
+        raise NotImplementedError  # pragma: no cover
 
     def load(self, persistence_path, persistence_file):
         """
@@ -51,7 +51,7 @@ def load(self, persistence_path, persistence_file):
         :param persistence_path: str
 
         """
-        raise NotImplementedError
+        raise NotImplementedError  # pragma: no cover
 
 
 class JobListPersistencePkl(JobListPersistence):

autosubmit/job/job_packager.py

@@ -470,7 +470,6 @@ def check_if_packages_are_ready_to_build(self):
                     if job.distance_weight > 3:
                         sorted_jobs.remove(job)
                 jobs_ready = sorted_jobs
-                pass
             except IndexError:
                 pass
         if len(jobs_ready) == 0:
@@ -867,7 +866,7 @@ def build_vertical_package(self, job, wrapper_info):
         return self.jobs_list
 
     def get_wrappable_child(self, job):
-        pass
+        pass  # pragma: no cover
 
     def _is_wrappable(self, job):
         """

autosubmit/job/job_packages.py

@@ -134,7 +134,7 @@ def _create_scripts_threaded(self, jobs: list[Job], configuration: 'AutosubmitCo
             self._job_scripts[jobs[i].name] = jobs[i].create_script(configuration)
 
     def _create_common_script(self, filename: str = ""):
-        pass
+        pass  # pragma: no cover
 
     def submit_unthreaded(self, configuration: 'AutosubmitConfig', only_generate: bool = False):
         """
@@ -225,7 +225,7 @@ def _send_files(self):
 
     def _do_submission(self, job_scripts=None, hold: bool = False):
         """ Submit package to the platform. """
-        pass
+        pass  # pragma: no cover
 
     def process_jobs_to_submit(self, job_id: str, hold: bool = False) -> None:
         for i, job in enumerate(self.jobs):
@@ -664,7 +664,7 @@ def _do_submission(self, job_scripts: dict[str, str] = None, hold: bool = False)
             self.jobs[i].wrapper_name = self.name
 
     def _common_script_content(self) -> str:
-        pass
+        pass  # pragma: no cover
 
 
 class JobPackageThreadWrapped(JobPackageThread):

autosubmit/log/log.py

@@ -177,7 +177,7 @@ class Log:
     log.addHandler(console_handler)
 
     def __init__(self):
-        pass
+        pass  # pragma: no cover
 
     def init_variables(self, file_path="") -> None:
         self.file_path = file_path

autosubmit/migrate/migrate.py

@@ -85,7 +85,7 @@ def migrate_pickup(self):
                             finished = False
                             pipeline_broke = False
                             Log.info(
-                                "Rsync launched {0} times. Can take up to 150 retries or until all data is transferred".format(
+                                "Rsync launched {0} times. Can take up to 150 retrials or until all data is transferred".format(
                                     rsync_retries + 1))
                             try:
                                 p.send_command(