Skip to content

Commit

Permalink
change naming of generated pipeline_interface.yaml #417
Browse files Browse the repository at this point in the history
  • Loading branch information
donaldcampbelljr committed Oct 10, 2023
1 parent 975c2ca commit f651045
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 5 deletions.
1 change: 1 addition & 0 deletions looper/cli_looper.py
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@
read_looper_config_file,
read_yaml_file,
initiate_looper_config,
init_generic_pipeline,
)


Expand Down
2 changes: 1 addition & 1 deletion looper/const.py
Original file line number Diff line number Diff line change
Expand Up @@ -205,7 +205,7 @@ def _get_apperance_dict(type, templ=APPEARANCE_BY_FLAG):
EXAMPLE_COMPUTE_SPEC_FMT = "k1=v1 k2=v2"
SUBMISSION_FAILURE_MESSAGE = "Cluster resource failure"
LOOPER_DOTFILE_NAME = "." + LOOPER_KEY + ".yaml"
LOOPER_GENERIC_PIPELINE = "generic_pipeline_interface.yaml"
LOOPER_GENERIC_PIPELINE = "pipeline_interface.yaml"
POSITIONAL = [PEP_CONFIG_FILE_KEY, "command"]
SELECTED_COMPUTE_PKG = "package"
EXTRA_KEY = "_cli_extra"
Expand Down
8 changes: 4 additions & 4 deletions looper/utils.py
Original file line number Diff line number Diff line change
Expand Up @@ -337,10 +337,10 @@ def init_generic_pipeline():

# Determine Generic Pipeline Interface
generic_pipeline_dict = {
"pipeline_name": "count_lines",
"pipeline_name": "default_pipeline_name",
"pipeline_type": "sample",
"output_schema": "output_schema.yaml",
"var_templates": {"pipeline": "{looper.piface_dir}/count_lines.sh"},
"var_templates": {"pipeline": "{looper.piface_dir}/pipeline.sh"},
"command_template": "{pipeline.var_templates.pipeline} {sample.file} "
"--output-parent {looper.sample_output_folder}",
}
Expand All @@ -349,10 +349,10 @@ def init_generic_pipeline():
if not os.path.exists(dest_file):
with open(dest_file, "w") as file:
yaml.dump(generic_pipeline_dict, file)
print(f"Generic pipeline interface successfully created at: {dest_file}")
print(f"Pipeline interface successfully created at: {dest_file}")
else:
print(
f"Generic pipeline interface file already exists `{dest_file}`. Skipping creation.."
f"Pipeline interface file already exists `{dest_file}`. Skipping creation.."
)

return True
Expand Down

0 comments on commit f651045

Please sign in to comment.