diff --git a/pkg/manager/worker/kubernetes/kubernetes.go b/pkg/manager/worker/kubernetes/kubernetes.go
index fee2c8b432b..91173a37f68 100644
--- a/pkg/manager/worker/kubernetes/kubernetes.go
+++ b/pkg/manager/worker/kubernetes/kubernetes.go
@@ -171,11 +171,14 @@ func (d *KubernetesWorkerInterface) UpdateWorkerStatus(studyId string) error {
 	}
 	for _, w := range ws {
 		if w.Status == api.State_RUNNING {
-			d.StoreWorkerLog(w.WorkerId)
 			c, err := d.IsWorkerComplete(w.WorkerId)
 			if err != nil {
 				return err
 			}
+			err = d.StoreWorkerLog(w.WorkerId)
+			if err != nil {
+				return err
+			}
 			if c {
 				err := d.db.UpdateWorker(w.WorkerId, api.State_COMPLETED)
 				if err != nil {