diff --git a/services/api.service.ts b/services/api.service.ts
index dd45544..931bd36 100644
--- a/services/api.service.ts
+++ b/services/api.service.ts
@@ -99,15 +99,15 @@ export default class ApiService extends Service {
 					console.log("Client connected via websocket!");
 
 					client.on("action", async (action) => {
+						console.log("ACCCCCTION", action);
 						switch (action.type) {
 							case "LS_IMPORT":
 								// 1. Send task to queue
-								const result = await this.broker.call(
+								await this.broker.call(
 									"import.newImport",
 									action.data,
 									{}
 								);
-								client.emit("LS_COVER_EXTRACTED", result);
 								break;
 						}
 					});
diff --git a/services/import.service.ts b/services/import.service.ts
index 16228b8..56efdba 100644
--- a/services/import.service.ts
+++ b/services/import.service.ts
@@ -80,6 +80,7 @@ export default class ImportService extends Service {
 								}>
 							) {
 								// 1. Walk the Source folder
+								
 								klaw(path.resolve(COMICS_DIRECTORY))
 									// 1.1 Filter on .cb* extensions
 									.pipe(
diff --git a/services/libraryqueue.service.ts b/services/libraryqueue.service.ts
index 144346b..bc3a6ca 100644
--- a/services/libraryqueue.service.ts
+++ b/services/libraryqueue.service.ts
@@ -28,6 +28,7 @@ export default class LibraryQueueService extends Service {
 					hooks: {},
 					queues: {
 						"process.import": {
+							concurrency: 30,
 							async process(job: SandboxedJob) {
 								console.info("New job received!", job.data);
 								console.info(`Processing queue...`);