diff --git a/translate.go b/translate.go
index 32bcc1126..41f3b4852 100644
--- a/translate.go
+++ b/translate.go
@@ -337,9 +337,7 @@ func (s *TranslateFile) monitorReplication() {
 		}
 
 		select {
-		case <-s.closing:
-			return
-		case <-s.replicationClosing:
+		case <-ctx.Done():
 			return
 		case <-time.After(s.replicationRetryInterval):
 			log.Printf("pilosa: reconnecting to primary replica")