{% if completed %}completed{% elif failed %}failed{% elif started %}running{% else %}unknown{% endif %}
Partition
{% if partition is not none %}{{ partition }}{% else %}-{% endif %}
Duration
{% if duration is not none %}{{ "%.3f"|format(duration) }}s{% else %}-{% endif %}
Exit Code
{% if completed %}{{ completed.exit_code }}{% elif failed %}{{ failed.exit_code or '-' }}{% else %}-{% endif %}
PID
{{ pid or '-' }}
{% if started %}
Started
{{ format_ts(started.ts) }}
{{ format_ts_full(started.ts) }}
{% if completed or failed %}
Finished
{% set fin = completed or failed %}
{{ format_ts(fin.ts) }}
{{ format_ts_full(fin.ts) }}
{% endif %}
{% if completed and completed.stdout_size %}
Stdout Size
{{ completed.stdout_size }} bytes
{% endif %}
{% endif %}
{% if labels %}
Labels
{% for key, val in labels.items() %}
{{ key }}={{ val }}
{% endfor %}
{% endif %}
{% if task_env %}
Environment Variables
{% for key, val in task_env.items() %}
{{ key }}={{ val }}
{% endfor %}
{% endif %}
{% if source_offsets %}
Source Message Offsets
{% for off in source_offsets %}
{{ partition }}:{{ off }}
{{ kafka_ui_icon(kafka_source_topic, partition, off) }}
{% endfor %}
{% endif %}
{% if args %}
CLI
{% if args is string %}
{% set parts = [args] %}
{% else %}
{% set parts = args %}
{% endif %}
{% set cli_line = binary_path ~ ' ' ~ parts | map('tojson') | join(' ') %}
{{ cli_line }}
{% endif %}
{% if completed and completed.stdout %}
Stdout
{{ completed.stdout }}
{% endif %}
{% if completed and completed.stderr %}
Stderr
{{ completed.stderr }}
{% endif %}
{% if failed and failed.stderr %}
Stderr
{{ failed.stderr }}
{% endif %}
Event Timeline
{% for e in events %}
{{ e.event }}
{% if e.exit_code is not none %}
exit={{ e.exit_code }}
{% endif %}
{% if e.duration is not none %}
{{ "%.3f"|format(e.duration) }}s
{% endif %}