diff --git a/client/driver/docker.go b/client/driver/docker.go index 8bd348b39..44531e4ee 100644 --- a/client/driver/docker.go +++ b/client/driver/docker.go @@ -690,6 +690,7 @@ func (h *DockerHandle) WaitCh() chan *cstructs.WaitResult { func (h *DockerHandle) Update(task *structs.Task) error { // Store the updated kill timeout. h.killTimeout = task.KillTimeout + h.logCollector.UpdateLogConfig(task.LogConfig) // Update is not possible return nil diff --git a/client/driver/exec.go b/client/driver/exec.go index eb5337dc3..c00a483b9 100644 --- a/client/driver/exec.go +++ b/client/driver/exec.go @@ -224,6 +224,7 @@ func (h *execHandle) WaitCh() chan *cstructs.WaitResult { func (h *execHandle) Update(task *structs.Task) error { // Store the updated kill timeout. h.killTimeout = task.KillTimeout + h.executor.UpdateLogConfig(task.LogConfig) // Update is not possible return nil diff --git a/client/driver/java.go b/client/driver/java.go index 7ac3611a5..f7d724efc 100644 --- a/client/driver/java.go +++ b/client/driver/java.go @@ -275,6 +275,7 @@ func (h *javaHandle) WaitCh() chan *cstructs.WaitResult { func (h *javaHandle) Update(task *structs.Task) error { // Store the updated kill timeout. h.killTimeout = task.KillTimeout + h.executor.UpdateLogConfig(task.LogConfig) // Update is not possible return nil diff --git a/client/driver/qemu.go b/client/driver/qemu.go index cd0cc0fd2..54e28bbbd 100644 --- a/client/driver/qemu.go +++ b/client/driver/qemu.go @@ -296,6 +296,7 @@ func (h *qemuHandle) WaitCh() chan *cstructs.WaitResult { func (h *qemuHandle) Update(task *structs.Task) error { // Store the updated kill timeout. h.killTimeout = task.KillTimeout + h.executor.UpdateLogConfig(task.LogConfig) // Update is not possible return nil diff --git a/client/driver/raw_exec.go b/client/driver/raw_exec.go index ed84f3180..6c8adace2 100644 --- a/client/driver/raw_exec.go +++ b/client/driver/raw_exec.go @@ -200,6 +200,7 @@ func (h *rawExecHandle) WaitCh() chan *cstructs.WaitResult { func (h *rawExecHandle) Update(task *structs.Task) error { // Store the updated kill timeout. h.killTimeout = task.KillTimeout + h.executor.UpdateLogConfig(task.LogConfig) // Update is not possible return nil