Check that the exit code is correct.

Return the database connection. It captures any exception, returning an ``AutosubmitCritical`` as in the previous SQLite-only code. With this

Convert job status from str to Status. :param s: status string :type s: str :return: status instance :rtype: Status

Unify filter_to filters into a single dictionary :param unified_filter: Single dictionary with all filters_to :param filter_t

Returns the minimum and maximum number of jobs that can be wrapped :param section_list: List of sections to be wrapped :type

Update a nested dictionary or similar mapping. Modify ``source`` in place.

Show details for specified experiment :param input_experiment_list: experiments identifier: :type input_experiment_list: str

Returns a dictionary with for each key, the difference between the current configuration and the last_run_data :param current_data: dictionary

Execute a command on the SSH server. A new ``.Channel`` is open and the requested command is executed. The command's input and output

Returns the default job type from experiment's config file. :return: default type such as bash, python, r... :rtype: str

Returns JobData data class for the latest job_data_row with last=1 by job_name.

Returns version number of the current experiment from autosubmit's config file :return: version :rtype: str

Apply some memory internal variables to normalize its format. (right now only dependencies) :param data: The input data dictionary t

Opens a connection to database :param check_version: If true, check if the database is compatible with this autosubmit version :type che

Parse arguments given to an executable and start execution of command given. Returns a tuple with the exit code (``status``), and an optional

Function to finish the profiling process.

Tests the connection using the provided configuration. :param as_conf: The configuration to use for testing the connection.

Updates job list, resetting failed jobs and changing to READY all WAITING jobs with all parents COMPLETED :param first_time:

Check if the current_job_value is included in the filter_from and retrieve filter_to value :param relationships: Remaining filters to

Check if the current_job_value is included in the filter_from and retrieve filter_to value :param relationships: Remaining filters to

Check if the current_job_value is included in the filter_from and retrieve filter_to value :param relationships: Remaining filters to

Verify if the message has arguments to format :param msg: message to show :param args: arguments for message formatting

Add special conditions to the job edge. :param job: Job :param special_conditions: dict :param filters_to_apply: dict

Calendar for chunks :param section: :param parameters: :return: int

Checks if database file exist. :return: None if exists, terminates program if not

Check if the packages are ready to be built. Returns a tuple with two elements. The first contains the list of jobs ready to be built.

Create the script file to be run for the job. :param as_conf: Configuration object. :type as_conf: AutosubmitConfig

Sends critical errors to the log. It will be shown in red in the console. :param msg: message to show :param args: arguments for mess

Deletes a file from this platform. :param filename: file name :type filename: str :return: True if successful or file does no

Used for tests only.\ Gets all content from job_data as list of Models.JobDataRow from database.

Puts a job into the queue if it is not a duplicate. :param job: The job to be added to the queue. :type job: Any :param block

Submit a job from a given job object. :param job: job object :type job: autosubmit.job.job.Job :param script_name: job script

Create the script content to be run for the job. :param as_conf: Autosubmit configuration. :param parameters: Parameters dictionary.

Add all files of a directory into the RO-Crate. Ignores existing crate archives. :param crate: the RO-Crate instance. :param base_path:

Create jobs to be run once per chunk :param synchronize: :param section: section to read :type section: str

Creates a sorting of the jobs whose job.section is in wrapper_jobs, according to the following filters in order of importance: date, m

Return a human-readable string with the number of day(s), and the time in the delta.

Get List of Models.JobDataRow for job_name and last=1

Raise an error if the jobs file does not exist. By default, it will search all jobs sections. Alternatively, callers can pass ``current_secti

Create an RO-Crate archive using the ro-crate-py library. It uses the Autosubmit configuration for the prospective provenance, and also to lo

Plots graph for joblist and stores it in a file :param hide_groups: :param groups: :param packages: :param p

Gets JobData data classes in job_data for last=1.

Unit for the chunk length :return: Unit for the chunk length Options: {hour, day, month, year} :rtype: str

Get inner date list. :return: date list :rtype: list

Returns a list of failed jobs. :param wrapper: :param platform: job platform :type platform: HPCPlatform :return: fai

Get the rows from a statement with no arguments

Get the rows from a statement with arguments

Returns a list of jobs in the platforms (Submitted, Running, Queuing, Unknown,Held). :param wrapper: :param platform: job platform

Returns git commit from experiment's config file :return: git commit :rtype: str

Returns the jobs that should be wrapped, configured in the autosubmit's config. :return: expression (or none) :rtype: string

Loads package of jobs from a database :param: wrapper: boolean :return: list of jobs per package

Create all the platform's object that will be used by the experiment.

Retrieve the process id of the autosubmit process. :param expid: An Autosubmit experiment ID. :type expid: str :param command: An Autosub

Run assertions against database values, checking for possible issues.

Assert that the files are recovered correctly.

Check that the database contains the expected number of entries, and that all fields contain data after a completed run.

Check that all files are recovered after a run.

Checks job running status. :param is_wrapper: :param submit_hold_check: :param job: :param retries: retries :

Check if all parents of a job have the correct status for checkpointing. :returns: jobs_to_check - Jobs that fulfill the special con

Clean the cloned Git repository inside the project directory of the experiment. Skipped if the project directory location is not a valid director

Normalize a nested dictionary or similar mapping to uppercase. This function recursively iterates through a dictionary, converting all keys t

Create a database connection to the SQLite database specified by path. :param path: database file name :return: Connection ob

Copies a file from the current platform to experiment's tmp folder :param wrapper_failed: :param ignore_log: :param filename:

Get a free TCP port to use in a test (e.g. for a Docker container). Creating a Socket in Python, and binding to port 0, triggers underlying c

Get the latest JobData for a given job_id and job_name. :param job_id: The job ID. :type job_id: int :param job_name

Configure the file to store the log. If another file was specified earlier, new messages will only go to the new file. :para

Returns what kind of wrapper (VERTICAL, MIXED-VERTICAL, HORIZONTAL, HYBRID, MULTI NONE) the user has configured in the autosubmit's config.

Adds all files in the given path, and creates a single commit for it.

Generates cmd files experiment. :param expid: identifier of experiment to be run :param lst: :param filter_chunks: