mirror of
https://github.com/kemko/nomad.git
synced 2026-01-01 16:05:42 +03:00
fix(plugins): should return when ctx.Done
This commit is contained in:
@@ -313,6 +313,7 @@ func (d *driverPluginClient) handleStats(ctx context.Context, ch chan<- *cstruct
|
||||
select {
|
||||
case ch <- stats:
|
||||
case <-ctx.Done():
|
||||
return
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user