diff --git a/pkg/worker/worker.go b/pkg/worker/worker.go
index f98b2e97..28c29b60 100644
--- a/pkg/worker/worker.go
+++ b/pkg/worker/worker.go
@@ -113,6 +113,7 @@ func (w *Worker) Start(done chan struct{}) {
 			case <-done:
 				return
 			default:
+				w.Reset()
 				cord, err := newCoordinatorConnection(remoteAddr, w.conf.Worker, w.address, w.log)
 				if err != nil {
 					onRetryFail(err)