update

data/cl104/cl104.go

@@ -42,11 +42,11 @@ func init() {
 	}
 }
 
-func ConnectCLs() {
+func ConnectCLs(ctx context.Context) {
 	for cl, ch := range cl2Chan {
 		go func(ctx context.Context, cl string, ch chan []byte) {
 			connectingCL(ctx, cl, ch)
-		}(context.Background(), cl, ch)
+		}(ctx, cl, ch)
 	}
 }
 

data/data.go

@@ -30,7 +30,7 @@ func (p *Processes) StartDataProcessing() {
 	updatingRedisPhasor(ctx)
 	updatingRedisCL104(ctx)
 
-	cl104.ConnectCLs()
+	cl104.ConnectCLs(ctx)
 }
 
 func (p *Processes) Cancel(ctx context.Context) {