fix(queue): debug info)

Author: dasein108

src/services/QueueManager/QueueManager.ts

@@ -59,15 +59,15 @@ const strategies = {
   external: new QueueStrategy(
     {
       db: { timeout: 5000, maxConcurrentExecutions: 999 },
-      node: { timeout: 60 * 1000, maxConcurrentExecutions: 50 },
+      node: { timeout: 60 * 1000, maxConcurrentExecutions: 30 },
       gateway: { timeout: 21000, maxConcurrentExecutions: 11 },
     },
     ['db', 'node', 'gateway']
   ),
   embedded: new QueueStrategy(
     {
       db: { timeout: 5000, maxConcurrentExecutions: 999 },
-      node: { timeout: 60 * 1000, maxConcurrentExecutions: 50 },
+      node: { timeout: 60 * 1000, maxConcurrentExecutions: 30 },
       gateway: { timeout: 21000, maxConcurrentExecutions: 11 },
     },
     ['db', 'gateway', 'node']
@@ -130,12 +130,16 @@ class QueueManager {
       const executeCount =
         settings.maxConcurrentExecutions -
         this.executing[queueSource as IpfsContentSource].size;
-
       const itemsByPriority = items
         .sort(
           (a, b) => getQueueItemTotalPriority(b) - getQueueItemTotalPriority(a)
         )
         .slice(0, executeCount);
+      console.log(
+        `----q ${queueSource} ${
+          this.executing[queueSource as IpfsContentSource].size
+        }/${settings.maxConcurrentExecutions} `
+      );
 
       // console.log('---itemsByPriority', itemsByPriority);
 

src/services/backend/workers/background/worker.ts

@@ -92,7 +92,6 @@ const createBackgroundWorkerApi = () => {
     if (!mlInstances[name]) {
       // broadcastApi.postServiceStatus('ml', 'starting');
       const model = mlModelMap[name];
-      console.log('-----------init ml pipeline');
 
       return pipeline(model.name, model.model, {
         progress_callback: (progressData: any) => {
@@ -162,7 +161,6 @@ const createBackgroundWorkerApi = () => {
   const syncService = new SyncService(serviceDeps, particlesResolver);
   const initMl = async () => {
     broadcastApi.postServiceStatus('ml', 'starting');
-    console.log('-----------init ml starting');
 
     return Promise.all([
       initMlInstance('featureExtractor'),