File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -14,6 +14,7 @@ import { RequeueV2Message } from "./requeueV2Message.server";
1414import  {  VisibilityTimeoutStrategy  }  from  "./types" ; 
1515import  Redis  from  "ioredis" ; 
1616import  {  FairDequeuingStrategy ,  NoopFairDequeuingStrategy  }  from  "./fairDequeuingStrategy.server" ; 
17+ import  {  tracer  }  from  "../tracer.server" ; 
1718
1819const  KEY_PREFIX  =  "marqsv2:" ; 
1920const  SHARED_QUEUE_NAME  =  "sharedQueue" ; 
@@ -74,8 +75,9 @@ function getMarQSClient() {
7475    visibilityTimeoutStrategy : new  V2VisibilityTimeout ( ) , 
7576    keysProducer : new  MarQSV2KeyProducer ( KEY_PREFIX ) , 
7677    queuePriorityStrategy : new  FairDequeuingStrategy ( { 
78+       tracer, 
7779      redis, 
78-       queueSelectionCount :  env . V2_MARQS_QUEUE_SELECTION_COUNT , 
80+       parentQueueLimit :  100 , 
7981      keys : new  MarQSV2KeyProducer ( KEY_PREFIX ) , 
8082      defaultEnvConcurrency : env . V2_MARQS_DEFAULT_ENV_CONCURRENCY , 
8183      defaultOrgConcurrency : env . DEFAULT_ORG_EXECUTION_CONCURRENCY_LIMIT , 
    
 
   
 
     
   
   
          
     
  
    
     
 
    
      
     
 
     
    You can’t perform that action at this time.
  
 
    
  
     
    
      
        
     
 
       
      
     
   
 
    
    
  
 
  
 
     
    
0 commit comments