We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4d3bc2d commit 107f4f9Copy full SHA for 107f4f9
internal/server/router/connection.go
@@ -35,6 +35,11 @@ func (cr *ConnectionRouter) Get(ctx *gin.Context) {
35
return
36
}
37
38
+ if conn.Status.Phase == tfv1.TensorFusionConnectionRunning {
39
+ ctx.JSON(200, conn.Status.ConnectionURL)
40
+ return
41
+ }
42
+
43
// Subscribe to connection updates
44
ch, cancelFunc := cr.watcher.subscribe(req)
45
defer cancelFunc()
internal/server/server.go
@@ -9,9 +9,11 @@ import (
9
func NewHTTPServer(
10
cr *router.ConnectionRouter,
11
) *gin.Engine {
12
13
r := gin.New()
14
r.Use(gzip.Gzip(gzip.DefaultCompression))
15
r.Use(gin.Recovery())
16
+ r.Use(gin.Logger())
17
18
apiGroup := r.Group("/api")
19
apiGroup.GET("/connection", cr.Get)
0 commit comments