from tfx import v1 as tfx
from tfx.types import standard_artifacts
example_gen = CsvExampleGen(input_base=data_path, input_config=input)
components.append(example_gen)
examples = example_gen.outputs['examples']
statistics_gen = StatisticsGen(examples=examples, stats_options=stats_options)

System information

• Have I specified the code to reproduce the issue (Yes, No):Yes
• Environment in which the code is executed (e.g., Local(Linux/MacOS/Windows),
  Interactive Notebook, Google Cloud, etc): Kubeflow 1.8 on Linux
• TensorFlow version: 2.16.2
• TFX Version: 1.16.0
• Python version: 3.10
• Python dependencies (from pip freeze output):
  kfp 2.0.1
  kfp-kubernetes 1.0.0
  kfp-pipeline-spec 0.2.2
  kfp-server-api 2.0.5

I0510 00:47:39.256530 50 launcher_v2.go:90] input ComponentSpec:{
"inputDefinitions": {
"artifacts": {
"examples": {
"artifactType": {
"instanceSchema": "title: tfx.Examples\ntype: object\nproperties:\n span:\n type: integer\n description: Span for an artifact.\n version:\n type: integer\n description: Version for an artifact.\n split_names:\n type: string\n description: JSON-encoded list of splits for an artifact. Empty string means artifact has no split.\n"
}
}
},
"parameters": {
"exclude_splits": {
"parameterType": "STRING"
},
"stats_options_json": {
"parameterType": "STRING"
}
}
},
"outputDefinitions": {
"artifacts": {
"statistics": {
"artifactType": {
"instanceSchema": "title: tfx.ExampleStatistics\ntype: object\nproperties:\n span:\n type: integer\n description: Span for an artifact.\n split_names:\n type: string\n description: JSON-encoded list of splits for an artifact. Empty string means artifact has no split.\n"
}
}
}
},
"executorLabel": "StatisticsGen_executor"
}
I0510 00:47:39.257013 50 cache.go:116] Connecting to cache endpoint ml-pipeline.kubeflow.svc.cluster.local:8887

Traceback (most recent call last):
File "/opt/conda/lib/python3.10/runpy.py", line 196, in _run_module_as_main
return _run_code(code, main_globals, None,
File "/opt/conda/lib/python3.10/runpy.py", line 86, in _run_code
exec(code, run_globals)
File "/opt/conda/lib/python3.10/site-packages/tfx/orchestration/kubeflow/v2/container/kubeflow_v2_run_executor.py", line 233, in
app.run(main, flags_parser=_parse_flags)
File "/opt/conda/lib/python3.10/site-packages/absl/app.py", line 308, in run
_run_main(main, args)
File "/opt/conda/lib/python3.10/site-packages/absl/app.py", line 254, in _run_main
sys.exit(main(argv))
File "/opt/conda/lib/python3.10/site-packages/tfx/orchestration/kubeflow/v2/container/kubeflow_v2_run_executor.py", line 229, in main
_run_executor(args, beam_args)
File "/opt/conda/lib/python3.10/site-packages/tfx/orchestration/kubeflow/v2/container/kubeflow_v2_run_executor.py", line 106, in _run_executor
inputs = kubeflow_v2_entrypoint_utils.parse_raw_artifact_dict(
File "/opt/conda/lib/python3.10/site-packages/tfx/orchestration/kubeflow/v2/container/kubeflow_v2_entrypoint_utils.py", line 61, in parse_raw_artifact_dict
result[k] = [
File "/opt/conda/lib/python3.10/site-packages/tfx/orchestration/kubeflow/v2/container/kubeflow_v2_entrypoint_utils.py", line 62, in
_parse_raw_artifact(single_artifact, name_from_id)
File "/opt/conda/lib/python3.10/site-packages/tfx/orchestration/kubeflow/v2/container/kubeflow_v2_entrypoint_utils.py", line 282, in _parse_raw_artifact
type_path = _retrieve_class_path(artifact_pb.type)
File "/opt/conda/lib/python3.10/site-packages/tfx/orchestration/kubeflow/v2/container/kubeflow_v2_entrypoint_utils.py", line 259, in _retrieve_class_path
title = data.get('title', 'tfx.Artifact')
AttributeError: 'NoneType' object has no attribute 'get'
I0510 00:47:50.040125 50 launcher_v2.go:151] publish success.
F0510 00:47:50.040148 50 main.go:49] failed to execute component: exit status 1
time="2025-05-10T00:47:50.253Z" level=info msg="sub-process exited" argo=true error=""
Error: exit status 1
time="2025-05-10T00:47:51.233Z" level=info msg="sub-process exited" argo=true error=""
Error: exit status 1