Support all backends

cschleiden · cschleiden · commit 7b98e4c1ba15 · 2023-01-15T21:15:53.000-08:00
diff --git a/backend/mysql/diagnostics.go b/backend/mysql/diagnostics.go
@@ -109,5 +109,6 @@ func (mb *mysqlBackend) GetWorkflowInstance(ctx context.Context, instanceID stri
 }
 
 func (mb *mysqlBackend) GetWorkflowTree(ctx context.Context, instanceID string) (*diag.WorkflowInstanceTree, error) {
-	panic("unimplemented")
+	itb := diag.NewInstanceTreeBuilder(mb)
+	return itb.BuildWorkflowInstanceTree(ctx, instanceID)
 }
diff --git a/backend/redis/diagnostics.go b/backend/redis/diagnostics.go
@@ -80,7 +80,6 @@ func (rb *redisBackend) GetWorkflowInstance(ctx context.Context, instanceID stri
 
 func (rb *redisBackend) GetWorkflowTree(ctx context.Context, instanceID string) (*diag.WorkflowInstanceTree, error) {
 	itb := diag.NewInstanceTreeBuilder(rb)
-
 	return itb.BuildWorkflowInstanceTree(ctx, instanceID)
 }
 
diff --git a/backend/sqlite/diagnostics.go b/backend/sqlite/diagnostics.go
@@ -109,5 +109,6 @@ func (sb *sqliteBackend) GetWorkflowInstance(ctx context.Context, instanceID str
 }
 
 func (sb *sqliteBackend) GetWorkflowTree(ctx context.Context, instanceID string) (*diag.WorkflowInstanceTree, error) {
-	panic("unimplemented")
+	itb := diag.NewInstanceTreeBuilder(sb)
+	return itb.BuildWorkflowInstanceTree(ctx, instanceID)
 }

Original file line number	Diff line number	Diff line change
`@@ -109,5 +109,6 @@ func (mb *mysqlBackend) GetWorkflowInstance(ctx context.Context, instanceID stri`
`109`	`109`	`}`
`110`	`110`
`111`	`111`	`func (mb mysqlBackend) GetWorkflowTree(ctx context.Context, instanceID string) (diag.WorkflowInstanceTree, error) {`
`112`		`- panic("unimplemented")`
	`112`	`+ itb := diag.NewInstanceTreeBuilder(mb)`
	`113`	`+ return itb.BuildWorkflowInstanceTree(ctx, instanceID)`
`113`	`114`	`}`
Original file line number	Diff line number	Diff line change
`@@ -80,7 +80,6 @@ func (rb *redisBackend) GetWorkflowInstance(ctx context.Context, instanceID stri`
`80`	`80`
`81`	`81`	`func (rb redisBackend) GetWorkflowTree(ctx context.Context, instanceID string) (diag.WorkflowInstanceTree, error) {`
`82`	`82`	`itb := diag.NewInstanceTreeBuilder(rb)`
`83`		`-`
`84`	`83`	`return itb.BuildWorkflowInstanceTree(ctx, instanceID)`
`85`	`84`	`}`
`86`	`85`
Original file line number	Diff line number	Diff line change
`@@ -109,5 +109,6 @@ func (sb *sqliteBackend) GetWorkflowInstance(ctx context.Context, instanceID str`
`109`	`109`	`}`
`110`	`110`
`111`	`111`	`func (sb sqliteBackend) GetWorkflowTree(ctx context.Context, instanceID string) (diag.WorkflowInstanceTree, error) {`
`112`		`- panic("unimplemented")`
	`112`	`+ itb := diag.NewInstanceTreeBuilder(sb)`
	`113`	`+ return itb.BuildWorkflowInstanceTree(ctx, instanceID)`
`113`	`114`	`}`