collectnode

type Record struct {
	Type         event.Type `json:"type"`
	Env          string     `json:"env"`
	Workspace    string     `json:"workspace"`
	TraceID      string     `json:"trace_id"`
	RunID        string     `json:"run_id"`
	ParentRunID  string     `json:"parent_run_id"`
	WorkflowID   string     `json:"workflow_id"`
	WorkflowVer  string     `json:"workflow_ver"`
	NodeID       string     `json:"node_id"`
	NodeName     string     `json:"node_name"`
	ParentNodeID string     `json:"parent_node_id"`
	NodePath     string     `json:"node_path"`
	NodeDepth    *int       `json:"node_depth"`
	NodeIndex    *int       `json:"node_index"`
	NodeType     string     `json:"node_type"`
	Status       string     `json:"status"`
	NodeStatus   string     `json:"node_status"`
	Error        string     `json:"error"`
	LogLevel     string     `json:"log_level"`
	Message      string     `json:"message"`
	StartedAt    *time.Time `json:"started_at"`
	EndedAt      *time.Time `json:"ended_at"`
	DurationMs   int64      `json:"duration_ms"`
	Attrs        string     `json:"attrs"`
	Fields       string     `json:"fields"`
}