diff --git a/downloader/downloaders/utils.go b/downloader/downloaders/utils.go
index c78199a..6b73759 100644
--- a/downloader/downloaders/utils.go
+++ b/downloader/downloaders/utils.go
@@ -8,4 +8,4 @@ const OUTPUT_DIR = "C:/Users/Administrator/ytdlpVideos"
 var ongoingDownloads = make(map[string]struct{})
 var ongoingDownloadsMutex = &sync.Mutex{}
 
-const DOWNLOAD_WORKERS = 2
+const DOWNLOAD_WORKERS = 4
diff --git a/downloader/main.go b/downloader/main.go
index 7edef60..8cac427 100644
--- a/downloader/main.go
+++ b/downloader/main.go
@@ -37,8 +37,8 @@ func init() {
 }
 
 //var downloader downloaders.Downloader = &downloaders.YTDLPRawDownloader{}
-var downloader downloaders.Downloader = &downloaders.KidaiDownloader{}
-//var downloader downloaders.Downloader = &downloaders.YTDLPLibDownloader{}
+// var downloader downloaders.Downloader = &downloaders.KidaiDownloader{}
+var downloader downloaders.Downloader = &downloaders.YTDLPLibDownloader{}
 
 type DLHandler struct{}
 
@@ -98,11 +98,14 @@ func main() {
 		consumer.AddHandler(&DLHandler{})
 	}
 
-	err = consumer.ConnectToNSQD("nsq.site.quack-lab.dev:41505")
+	url := "192.168.1.123:41505"
+	log.Printf("Connecting to nsq at %s", url)
+	err = consumer.ConnectToNSQD(url)
 	if err != nil {
-		Error.Printf("Error connecting to nsqlookupd: %v", err)
+		Error.Printf("Error connecting to nsq: %v", err)
 		return
 	}
+	log.Printf("Connected to nsq at %s", url)
 
 	sigChan := make(chan os.Signal, 1)
 	signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM)