feat: show cockpit run artifacts

api/v1/api.yaml

@@ -8473,6 +8473,9 @@ components:
         finishedAt:
           type: string
           description: "RFC 3339 timestamp when the DAG-run finished"
+        artifactsAvailable:
+          type: boolean
+          description: "Whether artifact files are available for this DAG-run"
         params:
           type: string
           description: "Runtime parameters passed to the DAG-run in JSON format"
@@ -8499,6 +8502,7 @@ components:
         - statusLabel
         - startedAt
         - finishedAt
+        - artifactsAvailable
         - autoRetryCount
 
     DAGRunDetails:
@@ -8526,9 +8530,6 @@ components:
             log:
               type: string
               description: "Path to the log file"
-            artifactsAvailable:
-              type: boolean
-              description: "Whether artifact endpoints are available for this DAG-run"
             nodes:
               type: array
               description: "Status of individual steps within the DAG-run"
@@ -8557,7 +8558,6 @@ components:
             - rootDAGRunName
             - rootDAGRunId
             - log
-            - artifactsAvailable
             - nodes
 
     ArtifactNodeType:

internal/service/frontend/api/v1/transformer.go

@@ -4,7 +4,10 @@
 package api
 
 import (
+	"os"
+
 	"github.com/dagucloud/dagu/api/v1"
+	"github.com/dagucloud/dagu/internal/cmn/fileutil"
 	"github.com/dagucloud/dagu/internal/core"
 	"github.com/dagucloud/dagu/internal/core/exec"
 )
@@ -190,23 +193,25 @@ func toDAGRunSummary(s exec.DAGRunStatus) api.DAGRunSummary {
 	if s.AutoRetryLimit > 0 {
 		autoRetryLimit = ptrOf(s.AutoRetryLimit)
 	}
+	artifactsAvailable := hasArtifactEntries(s.ArchiveDir)
 
 	return api.DAGRunSummary{
-		Name:           s.Name,
-		DagRunId:       s.DAGRunID,
-		Params:         ptrOf(s.Params),
-		QueuedAt:       ptrOf(s.QueuedAt),
-		AutoRetryCount: s.AutoRetryCount,
-		AutoRetryLimit: autoRetryLimit,
-		ScheduleTime:   ptrOf(s.ScheduleTime),
-		StartedAt:      s.StartedAt,
-		FinishedAt:     s.FinishedAt,
-		Status:         api.Status(s.Status),
-		StatusLabel:    api.StatusLabel(s.Status.String()),
-		WorkerId:       ptrOf(s.WorkerID),
-		TriggerType:    toTriggerType(s.TriggerType),
-		Labels:         &s.Labels,
-		Tags:           &s.Labels,
+		Name:               s.Name,
+		DagRunId:           s.DAGRunID,
+		Params:             ptrOf(s.Params),
+		QueuedAt:           ptrOf(s.QueuedAt),
+		AutoRetryCount:     s.AutoRetryCount,
+		AutoRetryLimit:     autoRetryLimit,
+		ScheduleTime:       ptrOf(s.ScheduleTime),
+		StartedAt:          s.StartedAt,
+		FinishedAt:         s.FinishedAt,
+		ArtifactsAvailable: artifactsAvailable,
+		Status:             api.Status(s.Status),
+		StatusLabel:        api.StatusLabel(s.Status.String()),
+		WorkerId:           ptrOf(s.WorkerID),
+		TriggerType:        toTriggerType(s.TriggerType),
+		Labels:             &s.Labels,
+		Tags:               &s.Labels,
 	}
 }
 
@@ -244,13 +249,14 @@ func ToDAGRunDetails(s exec.DAGRunStatus) api.DAGRunDetails {
 	if s.AutoRetryLimit > 0 {
 		autoRetryLimit = ptrOf(s.AutoRetryLimit)
 	}
+	artifactsAvailable := hasArtifactEntries(s.ArchiveDir)
 
 	return api.DAGRunDetails{
 		RootDAGRunName:     s.Root.Name,
 		RootDAGRunId:       s.Root.ID,
 		ParentDAGRunName:   ptrOf(s.Parent.Name),
 		ParentDAGRunId:     ptrOf(s.Parent.ID),
-		ArtifactsAvailable: s.ArchiveDir != "",
+		ArtifactsAvailable: artifactsAvailable,
 		Log:                s.Log,
 		Name:               s.Name,
 		Params:             ptrOf(s.Params),
@@ -276,6 +282,29 @@ func ToDAGRunDetails(s exec.DAGRunStatus) api.DAGRunDetails {
 	}
 }
 
+func hasArtifactEntries(archiveDir string) bool {
+	if archiveDir == "" {
+		return false
+	}
+
+	info, err := os.Stat(archiveDir)
+	if err != nil || !info.IsDir() {
+		return false
+	}
+
+	entries, err := os.ReadDir(archiveDir)
+	if err != nil {
+		return false
+	}
+
+	for _, entry := range entries {
+		if !fileutil.IsSymlinkDirEntry(entry) {
+			return true
+		}
+	}
+	return false
+}
+
 func toNode(node *exec.Node) api.Node {
 	if node == nil {
 		return api.Node{}

internal/service/frontend/api/v1/transformer_test.go

@@ -4,6 +4,8 @@
 package api
 
 import (
+	"os"
+	"path/filepath"
 	"testing"
 	"time"
 
@@ -14,12 +16,22 @@ import (
 	"github.com/stretchr/testify/require"
 )
 
+func writeArtifactFile(t *testing.T) string {
+	t.Helper()
+
+	dir := t.TempDir()
+	err := os.WriteFile(filepath.Join(dir, "artifact.txt"), []byte("artifact"), 0o600)
+	require.NoError(t, err)
+	return dir
+}
+
 func TestToDAGRunSummaryIncludesScheduleTime(t *testing.T) {
 	status := exec.DAGRunStatus{
 		Name:           "test-dag",
 		DAGRunID:       "run-1",
 		AutoRetryCount: 2,
 		AutoRetryLimit: 5,
+		ArchiveDir:     writeArtifactFile(t),
 		Status:         core.Queued,
 		ScheduleTime:   "2026-03-13T00:00:00Z",
 	}
@@ -30,6 +42,7 @@ func TestToDAGRunSummaryIncludesScheduleTime(t *testing.T) {
 	assert.Equal(t, status.AutoRetryCount, summary.AutoRetryCount)
 	require.NotNil(t, summary.AutoRetryLimit)
 	assert.Equal(t, status.AutoRetryLimit, *summary.AutoRetryLimit)
+	assert.True(t, summary.ArtifactsAvailable)
 }
 
 func TestToDAGRunDetailsIncludesScheduleTime(t *testing.T) {
@@ -38,6 +51,7 @@ func TestToDAGRunDetailsIncludesScheduleTime(t *testing.T) {
 		DAGRunID:       "run-1",
 		AutoRetryCount: 3,
 		AutoRetryLimit: 5,
+		ArchiveDir:     writeArtifactFile(t),
 		Status:         core.Queued,
 		QueuedAt:       "2026-03-13T00:01:00Z",
 		ScheduleTime:   "2026-03-13T00:00:00Z",
@@ -51,6 +65,7 @@ func TestToDAGRunDetailsIncludesScheduleTime(t *testing.T) {
 	assert.Equal(t, status.AutoRetryCount, details.AutoRetryCount)
 	require.NotNil(t, details.AutoRetryLimit)
 	assert.Equal(t, status.AutoRetryLimit, *details.AutoRetryLimit)
+	assert.True(t, details.ArtifactsAvailable)
 }
 
 func TestToDAGRunSummaryOmitsAutoRetryLimitWhenUnconfigured(t *testing.T) {
@@ -64,6 +79,7 @@ func TestToDAGRunSummaryOmitsAutoRetryLimitWhenUnconfigured(t *testing.T) {
 
 	summary := toDAGRunSummary(status)
 	assert.Nil(t, summary.AutoRetryLimit)
+	assert.False(t, summary.ArtifactsAvailable)
 }
 
 func TestToDAGRunDetailsOmitsAutoRetryLimitWhenUnconfigured(t *testing.T) {
@@ -77,6 +93,7 @@ func TestToDAGRunDetailsOmitsAutoRetryLimitWhenUnconfigured(t *testing.T) {
 
 	details := ToDAGRunDetails(status)
 	assert.Nil(t, details.AutoRetryLimit)
+	assert.False(t, details.ArtifactsAvailable)
 }
 
 func TestToDAGDetailsIncludesParamDefDescriptions(t *testing.T) {

ui/src/api/v1/schema.ts

@@ -3443,6 +3443,8 @@ export interface components {
             startedAt: string;
             /** @description RFC 3339 timestamp when the DAG-run finished */
             finishedAt: string;
+            /** @description Whether artifact files are available for this DAG-run */
+            artifactsAvailable: boolean;
             /** @description Runtime parameters passed to the DAG-run in JSON format */
             params?: string;
             /** @description ID of the worker that executed this DAG-run ('local' for local execution) */
@@ -3466,8 +3468,6 @@ export interface components {
             parentDAGRunId?: components["schemas"]["DAGRunId"] & unknown;
             /** @description Path to the log file */
             log: string;
-            /** @description Whether artifact endpoints are available for this DAG-run */
-            artifactsAvailable: boolean;
             /** @description Status of individual steps within the DAG-run */
             nodes: components["schemas"]["Node"][];
             onExit?: components["schemas"]["Node"];

ui/src/pages/docs/components/DocPreview.css → ui/src/components/ui/doc-markdown-preview.css

@@ -88,7 +88,8 @@
 
 /* Inline code */
 .doc-preview code {
-  font-family: 'JetBrains Mono', 'Fira Code', Menlo, Monaco, 'Courier New', monospace;
+  font-family:
+    'JetBrains Mono', 'Fira Code', Menlo, Monaco, 'Courier New', monospace;
   font-size: 0.85em;
   color: var(--foreground);
   background: var(--muted);

ui/src/components/ui/doc-markdown-preview.tsx

@@ -0,0 +1,60 @@
+import { MermaidBlock } from '@/components/ui/mermaid-block';
+import { cn } from '@/lib/utils';
+import { slugifyHeading } from '@/lib/text-utils';
+import type { ReactElement, ReactNode } from 'react';
+import ReactMarkdown from 'react-markdown';
+import remarkGfm from 'remark-gfm';
+import './doc-markdown-preview.css';
+
+type DocMarkdownPreviewProps = {
+  content: string | null | undefined;
+  className?: string;
+};
+
+function headingId(children: ReactNode): string {
+  const text =
+    typeof children === 'string'
+      ? children
+      : Array.isArray(children)
+        ? children
+            .map((child) => (typeof child === 'string' ? child : ''))
+            .join('')
+        : String(children ?? '');
+  return slugifyHeading(text);
+}
+
+export function DocMarkdownPreview({
+  content,
+  className,
+}: DocMarkdownPreviewProps) {
+  return (
+    <div className={cn('doc-preview max-w-none', className)}>
+      <ReactMarkdown
+        remarkPlugins={[remarkGfm]}
+        components={{
+          h1: ({ children }) => <h1 id={headingId(children)}>{children}</h1>,
+          h2: ({ children }) => <h2 id={headingId(children)}>{children}</h2>,
+          h3: ({ children }) => <h3 id={headingId(children)}>{children}</h3>,
+          h4: ({ children }) => <h4 id={headingId(children)}>{children}</h4>,
+          h5: ({ children }) => <h5 id={headingId(children)}>{children}</h5>,
+          h6: ({ children }) => <h6 id={headingId(children)}>{children}</h6>,
+          code({ className: codeClassName, children }) {
+            if (codeClassName === 'language-mermaid') {
+              return <MermaidBlock code={String(children)} />;
+            }
+            return <code className={codeClassName}>{children}</code>;
+          },
+          pre({ children }) {
+            const child = children as ReactElement;
+            if (child?.type === MermaidBlock) {
+              return <>{children}</>;
+            }
+            return <pre>{children}</pre>;
+          },
+        }}
+      >
+        {content ?? ''}
+      </ReactMarkdown>
+    </div>
+  );
+}