diff --git a/src/fmu/sumo/uploader/config_jobs/SUMO_UPLOAD b/src/fmu/sumo/uploader/config_jobs/SUMO_UPLOAD deleted file mode 100644 index b45b950..0000000 --- a/src/fmu/sumo/uploader/config_jobs/SUMO_UPLOAD +++ /dev/null @@ -1,23 +0,0 @@ --- This is the forward model job which uploads data to Sumo --- It is called from the ERT config file as a regular forward model - --- Arguments: --- SUMO_CASEPATH: The absolute path to the root of the case --- e.g. // --- SEARCHPATH: The searchpath relative to the realization root --- e.g "share/results/maps/*.gri" --- SUMO_ENV: The environment to upload to - -STDERR sumo_upload.stderr -STDOUT sumo_upload.stdout - -EXECUTABLE sumo_upload - - -ARGLIST - -MIN_ARG 2 -MAX_ARG 3 -ARG_TYPE 0 STRING -ARG_TYPE 1 STRING -ARG_TYPE 2 STRING diff --git a/src/fmu/sumo/uploader/hook_implementations/__init__.py b/src/fmu/sumo/uploader/hook_implementations/__init__.py deleted file mode 100644 index e69de29..0000000 diff --git a/src/fmu/sumo/uploader/hook_implementations/jobs.py b/src/fmu/sumo/uploader/hook_implementations/jobs.py deleted file mode 100644 index 29afadf..0000000 --- a/src/fmu/sumo/uploader/hook_implementations/jobs.py +++ /dev/null @@ -1,61 +0,0 @@ -import importlib -import os -from pkg_resources import resource_filename - -from ert.shared.plugins.plugin_manager import hook_implementation -from ert.shared.plugins.plugin_response import plugin_response - - -def _get_jobs_from_directory(directory): - """Do a filesystem lookup in a directory to check - for available ERT forward models""" - resource_directory = resource_filename("fmu", directory) - - all_files = [ - os.path.join(resource_directory, f) - for f in os.listdir(resource_directory) - if os.path.isfile(os.path.join(resource_directory, f)) - ] - return {os.path.basename(path): path for path in all_files} - - -# pylint: disable=no-value-for-parameter -@hook_implementation -@plugin_response(plugin_name="fmu_sumo") # pylint: disable=no-value-for-parameter -def installable_jobs(): - return _get_jobs_from_directory("sumo/config_jobs") - - -def _get_module_variable_if_exists(module_name, variable_name, default=""): - try: - script_module = importlib.import_module(module_name) - except ImportError: - return default - - return getattr(script_module, variable_name, default) - - -@hook_implementation -@plugin_response(plugin_name="fmu_sumo") # pylint: disable=no-value-for-parameter -def job_documentation(job_name): - sumo_fmu_jobs = set(installable_jobs().data.keys()) - if job_name not in sumo_fmu_jobs: - return None - - module_name = "jobs.scripts.{}".format(job_name.lower()) - - description = _get_module_variable_if_exists( - module_name=module_name, variable_name="description" - ) - examples = _get_module_variable_if_exists( - module_name=module_name, variable_name="examples" - ) - category = _get_module_variable_if_exists( - module_name=module_name, variable_name="category", default="other" - ) - - return { - "description": description, - "examples": examples, - "category": category, - }