diff --git a/apps/dag_engine/store/store.go b/apps/dag_engine/store/store.go index f2b605bb..df17c500 100644 --- a/apps/dag_engine/store/store.go +++ b/apps/dag_engine/store/store.go @@ -46,14 +46,14 @@ func (db *DB) Conn() *sql.DB { // DagRun mirrors infra.DagRun for the store layer. type DagRun struct { - ID string - DagName string - DagPath string - Status string - Trigger string - StartedAt time.Time - FinishedAt *time.Time - Error string + ID string `json:"id"` + DagName string `json:"dag_name"` + DagPath string `json:"dag_path"` + Status string `json:"status"` + Trigger string `json:"trigger"` + StartedAt time.Time `json:"started_at"` + FinishedAt *time.Time `json:"finished_at,omitempty"` + Error string `json:"error,omitempty"` } // CreateRun inserts a new run record. @@ -129,17 +129,17 @@ func (db *DB) ListRuns(dagName string, limit, offset int) ([]DagRun, int, error) // DagStepResult mirrors infra.DagStepResult for the store layer. type DagStepResult struct { - ID string - RunID string - StepName string - Status string - ExitCode int - Stdout string - Stderr string - StartedAt *time.Time - FinishedAt *time.Time - DurationMs int64 - Error string + ID string `json:"id"` + RunID string `json:"run_id"` + StepName string `json:"step_name"` + Status string `json:"status"` + ExitCode int `json:"exit_code"` + Stdout string `json:"stdout,omitempty"` + Stderr string `json:"stderr,omitempty"` + StartedAt *time.Time `json:"started_at,omitempty"` + FinishedAt *time.Time `json:"finished_at,omitempty"` + DurationMs int64 `json:"duration_ms"` + Error string `json:"error,omitempty"` } // InsertStepResult inserts a new step result. diff --git a/cpp/apps/dag_engine_ui b/cpp/apps/dag_engine_ui index 334943b7..44026d0a 160000 --- a/cpp/apps/dag_engine_ui +++ b/cpp/apps/dag_engine_ui @@ -1 +1 @@ -Subproject commit 334943b7db8dc98969e8ea8d3baf7a0c63be59df +Subproject commit 44026d0a70fbb441b307748c25d6a6e60bcf9e95