diff --git a/pm/sendermonitor.go b/pm/sendermonitor.go
index 9ab638bcf5..5a7ab40fed 100644
--- a/pm/sendermonitor.go
+++ b/pm/sendermonitor.go
@@ -486,8 +486,7 @@ func (sm *LocalSenderMonitor) watchPoolSizeChange() {
 			glog.Error(err)
 			continue
 		case <-sink:
-			poolSize := sm.tm.GetTranscoderPoolSize()
-			if poolSize.Cmp(lastPoolSize) != 0 {
+			if poolSize := sm.tm.GetTranscoderPoolSize(); poolSize.Cmp(lastPoolSize) != 0 {
 				sm.handlePoolSizeChange()
 				lastPoolSize = poolSize
 			}