From 849dcd20098ad8994c2f7a3b9977134fe5ef89bb Mon Sep 17 00:00:00 2001 From: Madhur Karampudi <142544288+vkarampudi@users.noreply.github.com> Date: Mon, 13 May 2024 13:39:31 -0700 Subject: [PATCH] Fix typo --- tfx/orchestration/kubeflow/v2/kubeflow_v2_dag_runner.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tfx/orchestration/kubeflow/v2/kubeflow_v2_dag_runner.py b/tfx/orchestration/kubeflow/v2/kubeflow_v2_dag_runner.py index ed610b7eef..a8ed8d46d9 100644 --- a/tfx/orchestration/kubeflow/v2/kubeflow_v2_dag_runner.py +++ b/tfx/orchestration/kubeflow/v2/kubeflow_v2_dag_runner.py @@ -94,7 +94,7 @@ def _write_pipeline_spec_to_file( documents = [pipeline_spec_dict] yaml.dump_all(documents, yaml_file, sort_keys=True) else: - with fileio.open(package_path, 'w') as json_file + with fileio.open(package_path, 'w') as json_file: json.dump(pipeline_job_dict, json_file, sort_keys=True)