diff --git a/src/fondant/executor.py b/src/fondant/executor.py index 778fd7011..afa7801cb 100644 --- a/src/fondant/executor.py +++ b/src/fondant/executor.py @@ -223,8 +223,9 @@ def upload_manifest(self, manifest: Manifest, save_path: t.Union[str, Path]): if is_kubeflow_output: # Save to the expected base path directory safe_component_name = self.spec.name.replace(" ", "_").lower() - base_path = self.metadata["base_path"] - save_path_base_path = f"{base_path}/{safe_component_name}/manifest.json" + save_path_base_path = ( + f"{manifest.base_path}/{safe_component_name}/manifest.json" + ) Path(save_path_base_path).parent.mkdir(parents=True, exist_ok=True) manifest.to_file(save_path_base_path) logger.info(f"Saving output manifest to {save_path_base_path}")