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";
14
14
import { VisibilityTimeoutStrategy } from "./types" ;
15
15
import Redis from "ioredis" ;
16
16
import { FairDequeuingStrategy , NoopFairDequeuingStrategy } from "./fairDequeuingStrategy.server" ;
17
+ import { tracer } from "../tracer.server" ;
17
18
18
19
const KEY_PREFIX = "marqsv2:" ;
19
20
const SHARED_QUEUE_NAME = "sharedQueue" ;
@@ -74,8 +75,9 @@ function getMarQSClient() {
74
75
visibilityTimeoutStrategy : new V2VisibilityTimeout ( ) ,
75
76
keysProducer : new MarQSV2KeyProducer ( KEY_PREFIX ) ,
76
77
queuePriorityStrategy : new FairDequeuingStrategy ( {
78
+ tracer,
77
79
redis,
78
- queueSelectionCount : env . V2_MARQS_QUEUE_SELECTION_COUNT ,
80
+ parentQueueLimit : 100 ,
79
81
keys : new MarQSV2KeyProducer ( KEY_PREFIX ) ,
80
82
defaultEnvConcurrency : env . V2_MARQS_DEFAULT_ENV_CONCURRENCY ,
81
83
defaultOrgConcurrency : env . DEFAULT_ORG_EXECUTION_CONCURRENCY_LIMIT ,
You can’t perform that action at this time.
0 commit comments