diff --git a/internal/app.go b/internal/app.go
index 8f92614..f15aa77 100644
--- a/internal/app.go
+++ b/internal/app.go
@@ -51,7 +51,7 @@ func MainApp(configPath string) {
 	premium.MonitorPremiumStatus(rd, zurglog)
 
 	workerOptions := ants.Options{
-		Nonblocking:  true,
+		// Nonblocking:  true,
 		PanicHandler: func(i interface{}) {},
 		Logger:       log.Named("worker"),
 	}
@@ -64,7 +64,7 @@ func MainApp(configPath string) {
 	defer workerPool.Release()
 
 	refreshOptions := ants.Options{
-		Nonblocking:  true,
+		// Nonblocking:  true,
 		PanicHandler: func(i interface{}) {},
 		Logger:       log.Named("refreshworker"),
 	}
@@ -78,7 +78,7 @@ func MainApp(configPath string) {
 	defer refreshPool.Release()
 
 	repairOptions := ants.Options{
-		Nonblocking:  true,
+		// Nonblocking:  true,
 		PanicHandler: func(i interface{}) {},
 		Logger:       log.Named("repairworker"),
 	}
diff --git a/internal/torrent/refresh.go b/internal/torrent/refresh.go
index da9ea35..547226c 100644
--- a/internal/torrent/refresh.go
+++ b/internal/torrent/refresh.go
@@ -121,7 +121,7 @@ func (t *TorrentManager) refreshTorrents() []string {
 
 // startRefreshJob periodically refreshes the torrents
 func (t *TorrentManager) startRefreshJob() {
-	_ = t.workerPool.Submit(func() {
+	_ = t.refreshPool.Submit(func() {
 		t.log.Info("Starting periodic refresh job")
 		for {
 			<-time.After(time.Duration(t.Config.GetRefreshEverySecs()) * time.Second)