Returns if the user has enabled the notifications from autosubmit's config file. :return: if notifications :rtype: string

Returns partition directive for the specified job :param job: job to create partition directive for :type job: Job :param het

Returns processors directive for the specified job :param job: job to create processors directive for :type job: Job :param h

Gets command to check if a job is running given process identifier :param job_id: process identifier :type job_id: int :retur

Get queue generating squeue command to the job selected. :param job_id: ID of a job. :param job_id: str :return: Gets estimat

Returns reservation directive for the specified job :param job: :param parameters: :param het: :return:

Get a running SSH container, its port, and an SSH config. NOTE: Different from its sibling functions in this module, this function may

Return dict with keys COMPLETED, FAILED, QUEUING, SUBMITTED, RUNNING, SUSPENDED, TOTAL.

Returns the list of SubJob objects with their corrected queue times in the case of jobs that belong to a wrapper.

Returns a list of submitted jobs. :param wrapper: :param hold: :param platform: job platform :type platform: HPCPlatf

Returns what kind of policy (flexible, strict, mixed ) the user has configured in the autosubmit's config. :return: wrapper type (or none)

Get all yaml files in a folder and return a list with the filenames :param yaml_folder: folder to search for yaml files :param ignore_

Clone a Git repository into the given path.

Returns true if job has any children, else return false :return: true if job has any children, otherwise return false :rtype

Increments fail count

Insert statement with arguments into path

Check if the current state is a deadlock. :param any_simple_packages: Flag indicating if there are any simple packages. :par

Check if the job is over the wallclock time, it is an alternative method to avoid platform issues.

Load custom HPCARCH parameters. :param parameters: Dictionary to populate with HPC values. If None, use self.experiment_data.

Check if any configuration file has been modified and needs to be reloaded. Returns: bool: True if a reload is needed, F

Stores a new experiment on the database and generates its identifier :param description: description of the experiment :param version: v

Parses the queue reason from the output of the command. :param output: output of the command. :param job_id: job id :return:

Prepare the run of the experiment. :param expid: a string with the experiment id. :param start_time: a string with the starting time

Updates current experiment_run row with totals calculated from job_list.

Process the not wrappable packages based on the policy. :param not_wrappeable_package_info: List of not wrappable package informatio

Parsers yaml data stored in the dictionary and calculates the components of the heterogeneous job if any.

Opens and reads a script. If it is not a BASH script it will fail :( Will strip away the line with the hash bang (#!) :para

Creates a shell script to remove multiple files in the remote and sets the appropriate permissions. :param filenames: A string containing the

Restores the SSH connection to the platform. This is where the first connection to a remote platform normally starts in an Autosubmit

Retrieves log files from the remote host. :param raise_error: If True, raises an error if the log files are not retrieved.

Sets autosubmit's version in autosubmit's config file :param autosubmit_version: autosubmit's version :type autosubmit_version: str

Sends status of jobs to the log. It will be shown in white in the console. :param msg: message to show :param args: arguments for mes

Sends failed status of jobs to the log. It will be shown in white in the console. :param msg: message to show :param args: arguments

Convert a string representation of truth to ``True`` or ``False``. True values are 'y', 'yes', 't', 'true', 'on', and '1'; false values are '

:param hold: :param configuration: Autosubmit basic configuration :type configuration: AutosubmitConfig object :param

Check if the output of the submit command contains an error message. :param output: output of the submit cmd :return: boolean

Updates commands for platforms

Requires ExperimentRun data class.

Check all jobs associated, and update their status either to complete or to Failed, and if job is still running appends it to they inner jobs

Update JobData data class. Returns the latest row from job_data by job_name. :param job_data_dc: The JobData data class instance con

Upsert the details of an experiment. :param exp_id: The ID of the experiment. :param user: The user that created the experim

Writes end timestamp to TOTAL_STATS file and jobs_data.db :param completed: True if the job has been completed, False otherwise

Writes submit date and time to the ``TOTAL_STATS`` file. It doesn't write if hold is True.

Adds a new child to the job :param new_child: new child to add :type new_child: Job

Check if a node exists and if it must be skipped or not. If the list of ``groups`` is empty, or if the given ``job`` name is not listed in th

Generate the starting time of a job found by a generated command. :param output: The output of a CMD command executed :param index: l

Calculate the MD5 checksum of a file in chunks to avoid high memory usage. :param file: A file-like object opened in binary mode. :re

Creates a CSV file with the table of the jobs aggregated by section or the jobs list. :param jobs_data: jobs data for the table :type jo

Create jobs to be run once per member :param section: section to read :type section: str :param priority: priority f

Create jobs to be run once per start date :param section: section to read :type section: str :param priority: priori

Create a node object for a graph. If the list of ``groups`` is provided, and contains only the ``job`` and no other elements, then unless ``h

Create a Paramiko SSH Client. Sets up all the attributes required by Autosubmit in the :class:`paramiko.SSHClient`. This code is in a separat

Creates a pdf with the table of the jobs aggregated by section or the jobs list. :param jobs_data: jobs data for the table :type jobs_da

Recursive function to map dependencies of dependencies

Function to clean space on ``BasicConfig.LOCAL_ROOT_DIR/plot`` directory. Removes all plots that pass the filter, keeping the newest two files on

Submit package to the platform.

Estimates the number of requested nodes. In the past we had ``ZeroDivisionError`` due to the number of ``tasks`` being set to ``0`` by defaul

Generates a title banner with the specified text. :param title: The title that will be shown in the banner. :type title: str :return

Get the status of the workflow action. :param jobs: list of jobs, used to infer the current workflow/action status. :return: a valid RO-Crate

Return: List of (current timestamp, current datetime str, status, rowstatus, id in job_data). One tuple per change.

Return any code not pushed to remotes in the given Git repository or submodules. If there are no code not pushed changes, return None. :para

Return the current memory consumption of the process in Bytes. :return: The current memory used by the process (Bytes). :rtype: int

Parses a user defined Date (from [experiment] DATELIST) to return a special String representation of that Date. :param date: String r

Each item in the job_list must have attributes: date, member, status_str.

Create a ``db_manager`` with the given parameters.

Return jobs filtered by status and/or platform as names or Job objects. :param status: Optional list of job statuses to filter by. :p