fix(frontend): Update TFX context naming pattern for TFX 1.2.0+.

frontend/src/lib/OutputArtifactLoader.ts

@@ -272,6 +272,7 @@ export class OutputArtifactLoader {
 
     // Since artifact types don't change per run, this can be optimized further so
     // that we don't fetch them on every page load.
+    console.log('enter TFX for execution ' + execution.getId() + ' namespace ' + namespace);
     reportProgress(10);
     const [artifactTypes, artifacts] = await Promise.all([
       getArtifactTypes(),

frontend/src/mlmd/MlmdUtils.ts

@@ -70,17 +70,9 @@ async function getContext({ type, name }: { type: string; name: string }): Promi
  * @throws error when network error, or not found
  */
 async function getTfxRunContext(argoWorkflowName: string): Promise<Context> {
-  // argoPodName has the general form "pipelineName-workflowId-executionId".
-  // All components of a pipeline within a single run will have the same
-  // "pipelineName-workflowId" prefix.
-  const pipelineName = argoWorkflowName
-    .split('-')
-    .slice(0, -1)
-    .join('_');
-  const runID = argoWorkflowName;
-  // An example run context name is parameterized_tfx_oss.parameterized-tfx-oss-4rq5v.
-  const tfxRunContextName = `${pipelineName}.${runID}`;
-  return await getContext({ name: tfxRunContextName, type: 'run' });
+  // Context: https://github.com/kubeflow/pipelines/issues/6138
+  // Require TFX version to be > 1.2.0.
+  return await getContext({ name: argoWorkflowName, type: 'pipeline_run' });
 }
 
 /**

frontend/src/pages/RunDetails.tsx

@@ -267,6 +267,7 @@ class RunDetails extends Page<RunDetailsInternalProps, RunDetailsState> {
       workflow,
       selectedNodeId,
     );
+    console.log('selectedNodeId ' + selectedNodeId);
     const selectedExecution = mlmdExecutions?.find(
       execution => ExecutionHelpers.getKfpPod(execution) === selectedNodeId,
     );