diff --git a/plugins/drivers/client.go b/plugins/drivers/client.go index fd835ee53..592d47b74 100644 --- a/plugins/drivers/client.go +++ b/plugins/drivers/client.go @@ -313,6 +313,7 @@ func (d *driverPluginClient) handleStats(ctx context.Context, ch chan<- *cstruct select { case ch <- stats: case <-ctx.Done(): + return } } }