Publish typed values with bounded repeat timing

[onehouse] / driver / runner.go

diff --git a/driver/runner.go b/driver/runner.go
index e918416a7a4e02b585c84c3c82fade7b9ad8a00b..287c333cb75cb7706cf6a82720bc23fd24ab5dc9 100644 (file)
--- a/driver/runner.go
+++ b/driver/runner.go
@@ -31,7 +31,10 @@ func Run(ctx context.Context, drivers []Driver, connected <-chan struct{}) error
 
        for index, integration := range drivers {
                workers.Go(func() {
 
        for index, integration := range drivers {
                workers.Go(func() {

-                       results <- driverResult{index: index, err: integration.Run(ctx)}
+                       results <- driverResult{
+                               index: index,
+                               err:   integration.Run(ctx),
+                       }

                })
        }
 
                })
        }