File tree Expand file tree Collapse file tree 6 files changed +54
-0
lines changed Expand file tree Collapse file tree 6 files changed +54
-0
lines changed Original file line number Diff line number Diff line change @@ -59,6 +59,9 @@ RUN mkdir /opt/app-root/runtimes && \
59
59
# Workaround for passing ssl_sa_cert
60
60
patch /opt/app-root/lib/python3.8/site-packages/elyra/pipeline/kfp/kfp_authentication.py -i utils/kfp_authentication.patch && \
61
61
patch /opt/app-root/lib/python3.8/site-packages/elyra/pipeline/kfp/processor_kfp.py -i utils/processor_kfp.patch && \
62
+ # Workaround for elyra pipeline validation command
63
+ patch /opt/app-root/lib/python3.8/site-packages/elyra/cli/pipeline_app.py -i utils/pipeline_app.patch && \
64
+ patch /opt/app-root/lib/python3.8/site-packages/elyra/pipeline/pipeline_definition.py -i utils/pipeline_definition.patch && \
62
65
# switch to Data Science Pipeline in component catalog \
63
66
DIR_COMPONENT="/opt/app-root/lib/python3.8/site-packages/elyra/metadata/schemas/local-directory-catalog.json" && \
64
67
FILE_COMPONENT="/opt/app-root/lib/python3.8/site-packages/elyra/metadata/schemas/local-file-catalog.json" && \
Original file line number Diff line number Diff line change
1
+ --- a/pipeline_app.py 2023-11-09 13:36:35
2
+ +++ b/pipeline_app.py 2023-11-09 12:10:35
3
+ @@ -296,7 +296,8 @@
4
+ _validate_pipeline_definition(pipeline_definition)
5
+ except Exception:
6
+ raise click.ClickException("Pipeline validation FAILED.")
7
+ -
8
+ +
9
+ + print_info("Pipeline validation SUCCEEDED.", [])
10
+
11
+ def validate_timeout_option(ctx, param, value):
12
+ """Callback for monitor-timeout parameter validation"""
Original file line number Diff line number Diff line change
1
+ --- a/pipeline_definition.py 2023-11-09 13:36:35
2
+ +++ b/pipeline_definition.py 2023-11-07 20:07:49
3
+ @@ -265,6 +265,9 @@
4
+ if parameter_class is None:
5
+ return None # runtime type does not support parameters, skip
6
+
7
+ + if not ElyraProperty.subclass_exists_for_property(parameter_class.property_id):
8
+ + ElyraProperty.build_property_map()
9
+ +
10
+ # Convert pipeline parameters to runtime-specific instances
11
+ converted_value = ElyraProperty.create_instance(parameter_class.property_id, self.pipeline_parameters)
12
+ if converted_value is not None:
Original file line number Diff line number Diff line change @@ -59,6 +59,9 @@ RUN mkdir /opt/app-root/runtimes && \
59
59
# Workaround for passing ssl_sa_cert and to ensure that Elyra redirects to a correct pipeline run URL
60
60
patch /opt/app-root/lib/python3.9/site-packages/elyra/pipeline/kfp/kfp_authentication.py -i utils/kfp_authentication.patch && \
61
61
patch /opt/app-root/lib/python3.9/site-packages/elyra/pipeline/kfp/processor_kfp.py -i utils/processor_kfp.patch && \
62
+ # Workaround for elyra pipeline validation command
63
+ patch /opt/app-root/lib/python3.9/site-packages/elyra/cli/pipeline_app.py -i utils/pipeline_app.patch && \
64
+ patch /opt/app-root/lib/python3.9/site-packages/elyra/pipeline/pipeline_definition.py -i utils/pipeline_definition.patch && \
62
65
# switch to Data Science Pipeline in component catalog \
63
66
DIR_COMPONENT="/opt/app-root/lib/python3.9/site-packages/elyra/metadata/schemas/local-directory-catalog.json" && \
64
67
FILE_COMPONENT="/opt/app-root/lib/python3.9/site-packages/elyra/metadata/schemas/local-file-catalog.json" && \
Original file line number Diff line number Diff line change
1
+ --- a/pipeline_app.py 2023-11-09 13:36:35
2
+ +++ b/pipeline_app.py 2023-11-09 12:10:35
3
+ @@ -296,7 +296,8 @@
4
+ _validate_pipeline_definition(pipeline_definition)
5
+ except Exception:
6
+ raise click.ClickException("Pipeline validation FAILED.")
7
+ -
8
+ +
9
+ + print_info("Pipeline validation SUCCEEDED.", [])
10
+
11
+ def validate_timeout_option(ctx, param, value):
12
+ """Callback for monitor-timeout parameter validation"""
Original file line number Diff line number Diff line change
1
+ --- a/pipeline_definition.py 2023-11-09 13:36:35
2
+ +++ b/pipeline_definition.py 2023-11-07 20:07:49
3
+ @@ -265,6 +265,9 @@
4
+ if parameter_class is None:
5
+ return None # runtime type does not support parameters, skip
6
+
7
+ + if not ElyraProperty.subclass_exists_for_property(parameter_class.property_id):
8
+ + ElyraProperty.build_property_map()
9
+ +
10
+ # Convert pipeline parameters to runtime-specific instances
11
+ converted_value = ElyraProperty.create_instance(parameter_class.property_id, self.pipeline_parameters)
12
+ if converted_value is not None:
You can’t perform that action at this time.
0 commit comments