Get the dictionary of jobs ordered according to wrapper's expression divided by date and member. :return: jobs ordered divided by dat

Returns two-step start jobs :return: jobs_list :rtype: str

Find the autosubmit project root. :return: The project root path. :rtype: Path :raises FileNotFoundError: If the project root direct

Returns queue directive for the specified job :param job: job to create queue directive for :type job: Job :param parameters:

Returns a list of jobs queuing. :param wrapper: :param platform: job platform :type platform: HPCPlatform :return: qu

Get the ``.autosubmit.rc`` path. If the environment variable ``AUTOSUBMIT_CONFIGURATION`` is specified in the system, this function will retu

Returns startdates list from experiment's config file :return: rerun value :rtype: bool

Returns rerun jobs :return: jobs_list :rtype: str

Returns a list of jobs running. :param wrapper: :param platform: job platform :type platform: HPCPlatform :return: ru

Returns the storage system from autosubmit's config file. Pkl by default. :return: communications library

Returns memory per task directive for the specified job :param job: job to create tasks per node directive for :type job: Job

>>> get_template_snippet(Language.PYTHON).__name__ 'autosubmit.job.template.python3' >>> get_template_snippet(None) Traceback (most r

Returns threads per task directive for the specified job :param job: job to create threads per task directive for :type job: Job

Returns max number of running jobs from autosubmit's config file :return: max number of running jobs :rtype: int

Returns time to check the status of jobs in the wrapper. :return: wrapper check time :rtype: int

Returns the strategy for creating the machinefiles in wrapper jobs. :return: machinefiles function to use

Returns true only if there are 4 fields: submit start finish status, and status equals COMPLETED.

Check if the given job is a parent :param job: job to be checked if is a parent :return: True if job is a parent, false other

Checks if it is a valid experiment identifier :param name: experiment identifier to check :type name: str :return: name if is valid,

Loads all environment variables that starts with AS_ENV into the parameters dictionary and obtains the current user running it. :para

Loads custom config files :param current_data: dict with current data :param filenames_to_load: list of filenames to load :ret

Load the workflow commit from the .git folder.

Get next experiment identifier :param current_id: previous experiment identifier :type current_id: str :return: new experiment ident

Number of nodes that the job will use.

Parses check jobs command output, so it can be interpreted by autosubmit :param output: output to parse :param job_id: select the job

Parse githooks section in configuration file.

Parse a list of lines representing a job list and return a list of root nodes. :param lines: List of lines to parse. :type lines: List[s

Parse the number of processors. If the given value does not have ``:``, then if the value is a valid digit in Python, we return its integer v

Tries to find a backup of the pkl file and restores it. Verifies that autosubmit is not running on this experiment. :param expid: exp

Process the historical data for the current iteration. :param job_list: a JobList object. :param job_changes_tracker: a dictionary wi

Builds a dictionary of jobname -> SubJob object.

Process the metrics of the job

Calculates and returns the queuing time of the job, in seconds. :return: Queueing time in seconds. :rtype: int

Recovers log files for jobs from the recovery queue and retries failed jobs. :param identifier: Identifier for logging purposes. :par

Recover job IDs and log names for completed, failed, and skipped jobs from experiment history. :param finished_jobs: Optional list of finished

Wrapper function to recover platform job logs. :param platform: The platform object responsible for managing the connection and job recovery.

Remove noise from a list of lines by stripping whitespace and specific substrings. :param lines: List of lines to process. :type lines:

Removes all jobs to be run only in reruns.

Updates job list to rerun the jobs specified by a job list. :param job_list_unparsed: list of jobs to rerun :type job_list_unparsed:

Retrieve job timestamps from database. :param job_data_collection: :param seconds: :param status_code: Code of the St

Run the given target function in a separate thread. :param target: The function to execute in the thread. :type target: Callable[..., Any]

Calculates and returns the running time of the job, in seconds. :return: Running time in seconds. :rtype: int

Set the experiment_status row as running.

Set status of jobs. :param expid: experiment id :param noplot: do not plot :param save: save :param final: final stat

Store the metric value in the database

Gets READY jobs and send them to the platforms if there is available space on the queues. :param hold: :param as_conf: autosubmit con

Unarchives an experiment: uncompress folder from tar.gz and moves to experiment root folder. :param experiment_id: experiment identifier

Return updated row as Models.ExperimentRun.

When we have created the job list, every type of job is created. Update genealogy remove jobs that have no templates.

Return length of updated list.

Find and substitute dynamic placeholders in `parameters` using the provided Autosubmit configuration helpers. :param as_conf: Autosub

Refresh experiment version with the current autosubmit version. :param expid: experiment identifier :type expid: str

Wait for SSH. Testing the TCP port is not enough as the SSH service may not have fully initiated yet. Testing the SSH banner also may gi

Tries to connect to host and port until it works or the timeout is reached.

Waits a mandatory time and then waits until there is work, no work to more process or the cleanup event is set. :param sleep_time: M

Waits until a file is locked or unlocked.

Waits for the work_event to be set or the cleanup_event to be set for a mandatory time. :param sleep_time: Minimum time to wait in seconds. D

Waits until the timeout is reached or any signal is set to process logs. :param timeout: Maximum time to wait in seconds. Defaults to 60.

Writes start date and time to TOTAL_STATS file :return: True if successful, False otherwise :rtype: bool

Updates the start time and other details of a job in the database. :param job_name: The name of the job. :type job_name: str

Initializes the Platform object with the given experiment ID, platform name, configuration, and optional authentication password for two-facto