From 457a2ae016f3ed92ecccfe9e879c8282cc79243a Mon Sep 17 00:00:00 2001 From: Florez Ospina Juan Felipe Date: Sat, 7 Jun 2025 20:01:02 +0200 Subject: [PATCH] Update workflow step names --- pipelines/steps/prepare_ebas_submission.py | 2 +- pipelines/steps/visualize_datatable_vars.py | 2 +- workflows/workflow_acsm_data_PAY_2024.yaml | 32 ++------------------- 3 files changed, 4 insertions(+), 32 deletions(-) diff --git a/pipelines/steps/prepare_ebas_submission.py b/pipelines/steps/prepare_ebas_submission.py index bfb5ab4..50ddc3f 100644 --- a/pipelines/steps/prepare_ebas_submission.py +++ b/pipelines/steps/prepare_ebas_submission.py @@ -239,7 +239,7 @@ def main(paths_to_processed_files : list, path_to_flags : str, month : str = Non workflowfile_builder = RenkuWorkflowBuilder(name=workflow_name) workflowfile_builder.add_step( - step_name=f"{workflow_name}_step", + step_name=f"prepare_ebas_submission", base_command="python", inputs=inputs, outputs=outputs, diff --git a/pipelines/steps/visualize_datatable_vars.py b/pipelines/steps/visualize_datatable_vars.py index e4ce9a0..5ceacbd 100644 --- a/pipelines/steps/visualize_datatable_vars.py +++ b/pipelines/steps/visualize_datatable_vars.py @@ -24,7 +24,7 @@ import plotly.graph_objects as go def visualize_table_variables(data_file_path, dataset_name, flags_dataset_name, x_var, y_vars, yaxis_range_dict={'FlowRate_ccs': [0, 100]}, capture_renku_metadata=False, - workflow_name="visualize_table_variables"): + workflow_name="visualize_flagged_variables"): if not os.path.exists(data_file_path): raise ValueError(f"Path to input file {data_file_path} does not exists. The parameter 'data_file_path' must be a valid path to a suitable HDF5 file. ") diff --git a/workflows/workflow_acsm_data_PAY_2024.yaml b/workflows/workflow_acsm_data_PAY_2024.yaml index 2c55408..7ba1c9f 100644 --- a/workflows/workflow_acsm_data_PAY_2024.yaml +++ b/workflows/workflow_acsm_data_PAY_2024.yaml @@ -119,7 +119,7 @@ steps: parameters: - month_range: value: 2-3 - visualize_diagnostic_variables: + visualize_flagged_variables: command: python $script_py $data_file $dataset_name $flags_dataset_name $x_var $y_vars $fig_0_VaporizerTemp_C $fig_1_FlowRate_ccs $fig_2_FilamentEmission_mA $fig_3_ABsamp @@ -153,32 +153,4 @@ steps: - FlowRate_ccs - FilamentEmission_mA - ABsamp - workflow_acsm_data_PAY_2024_step: - command: python $script_py $in_1 $in_2 $in_3 $in_4 $month_range - inputs: - - script_py: - path: pipelines/steps/prepare_ebas_submission.py - - in_1: - path: data/collection_PAY_2024_2025-06-06_2025-06-06/ACSM_TOFWARE_processed/2024/ACSM_PAY_2024_timeseries_calibrated.csv - - in_2: - path: data/collection_PAY_2024_2025-06-06_2025-06-06/ACSM_TOFWARE_processed/2024/ACSM_PAY_2024_timeseries_calibrated_err.csv - - in_3: - path: data/collection_PAY_2024_2025-06-06_2025-06-06/ACSM_TOFWARE_processed/2024/ACSM_PAY_2024_timeseries_calibration_factors.csv - - in_4: - path: data/collection_PAY_2024_2025-06-06_2025-06-06/ACSM_TOFWARE_flags/2024/ACSM_PAY_2024_timeseries_flags.csv - - lod: - path: pipelines/params/"limits_of_detection.yaml - implicit: true - - station: - path: pipelines/params/"station_params.yaml - implicit: true - outputs: - - out_1: - path: data/PAY_ACSM-092_2024.txt - implicit: true - - out_2: - path: data/PAY_ACSM-092_FLAGS_2024.txt - implicit: true - parameters: - - month_range: - value: 2-3 + \ No newline at end of file