Warning

This document is for an in-development version of Galaxy. You can alternatively view this page in the latest release if it exists or view the top of the latest release's documentation.

galaxy.job_execution package¶

Submodules¶

galaxy.job_execution.datasets module¶

Utility classes allowing Job interface to reason about datasets.

galaxy.job_execution.datasets.dataset_path_rewrites(dataset_paths)[source]¶

class galaxy.job_execution.datasets.DatasetPath(dataset_id, real_path, false_path=None, false_extra_files_path=None, mutable=True)[source]¶

Bases: object

__init__(dataset_id, real_path, false_path=None, false_extra_files_path=None, mutable=True)[source]¶

with_path_for_job(false_path, false_extra_files_path=None)[source]¶: Clone the dataset path but with a new false_path.

class galaxy.job_execution.datasets.DatasetPathRewriter[source]¶

Bases: object

Used by runner to rewrite paths.

rewrite_dataset_path(dataset, dataset_type)[source]¶: Dataset type is ‘input’ or ‘output’. Return None to indicate not to rewrite this path.

class galaxy.job_execution.datasets.NullDatasetPathRewriter[source]¶

Bases: object

Used by default for jobwrapper, do not rewrite anything.

rewrite_dataset_path(dataset, dataset_type)[source]¶: Keep path the same.

class galaxy.job_execution.datasets.OutputsToWorkingDirectoryPathRewriter(working_directory)[source]¶

Bases: object

Rewrites all paths to place them in the specified working directory for normal jobs when Galaxy is configured with app.config.outputs_to_working_directory. Job runner base class is responsible for copying these out after job is complete.

__init__(working_directory)[source]¶

rewrite_dataset_path(dataset, dataset_type)[source]¶: Keep path the same.

class galaxy.job_execution.datasets.TaskPathRewriter(working_directory, job_dataset_path_rewriter)[source]¶

Bases: object

Rewrites all paths to place them in the specified working directory for TaskWrapper. TaskWrapper is responsible for putting them there and pulling them out.

__init__(working_directory, job_dataset_path_rewriter)[source]¶

rewrite_dataset_path(dataset, dataset_type)[source]¶

galaxy.job_execution.output_collect module¶

Code allowing tools to define extra files associated with an output datset.

class galaxy.job_execution.output_collect.PermissionProvider(inp_data, security_agent, job)[source]¶

Bases: object

__init__(inp_data, security_agent, job)[source]¶

permissions¶

set_default_hda_permissions(primary_data)[source]¶

copy_dataset_permissions(init_from, primary_data)[source]¶

class galaxy.job_execution.output_collect.MetadataSourceProvider(inp_data)[source]¶

Bases: object

__init__(inp_data)[source]¶

get_metadata_source(input_name)[source]¶

galaxy.job_execution.output_collect.collect_dynamic_outputs(job_context, output_collections)[source]¶

class galaxy.job_execution.output_collect.JobContext(tool, tool_provided_metadata, job, job_working_directory, permission_provider, metadata_source_provider, input_dbkey, object_store)[source]¶

Bases: galaxy.model.store.discover.ModelPersistenceContext

__init__(tool, tool_provided_metadata, job, job_working_directory, permission_provider, metadata_source_provider, input_dbkey, object_store)[source]¶

work_context¶

user¶

tag_handler¶

find_files(output_name, collection, dataset_collectors)[source]¶

persist_object(obj)[source]¶

flush()[source]¶

create_library_folder(parent_folder, name, description)[source]¶

add_output_dataset_association(name, dataset)[source]¶

add_library_dataset_to_folder(library_folder, ld)[source]¶

add_datasets_to_history(datasets, for_output_dataset=None)[source]¶

galaxy.job_execution.output_collect.collect_primary_datasets(job_context, output, input_ext)[source]¶

galaxy.job_execution.output_collect.discover_files(output_name, tool_provided_metadata, extra_file_collectors, job_working_directory, matchable)[source]¶

galaxy.job_execution.output_collect.walk_over_file_collectors(extra_file_collectors, job_working_directory, matchable)[source]¶

galaxy.job_execution.output_collect.walk_over_extra_files(target_dir, extra_file_collector, job_working_directory, matchable)[source]¶: Walks through all files in a given directory, and returns all files that match the given collector’s match criteria. If the collector has the recurse flag enabled, will also recursively descend into child folders.

galaxy.job_execution.output_collect.dataset_collector(dataset_collection_description)[source]¶

class galaxy.job_execution.output_collect.ToolMetadataDatasetCollector(dataset_collection_description)[source]¶

Bases: object

__init__(dataset_collection_description)[source]¶

class galaxy.job_execution.output_collect.DatasetCollector(dataset_collection_description)[source]¶

Bases: object

__init__(dataset_collection_description)[source]¶

match(dataset_instance, filename, path=None)[source]¶

sort(matches)[source]¶

galaxy.job_execution.output_collect.read_exit_code_from(exit_code_file, id_tag)[source]¶: Read exit code reported for a Galaxy job.

galaxy.job_execution.output_collect.default_exit_code_file(files_dir, id_tag)[source]¶

galaxy.job_execution.output_collect.collect_extra_files(object_store, dataset, job_working_directory)[source]¶