@@ -73,14 +73,12 @@ private RunDataProcessingTasks(
7373 InstanceProperties instanceProperties ,
7474 TaskCounts taskCounts ,
7575 CompactionTaskHostScaler hostScaler ,
76- TaskLauncher taskLauncher ,
77- boolean compactionTask ) {
76+ TaskLauncher taskLauncher ) {
7877 this .instanceProperties = instanceProperties ;
7978 this .taskCounts = taskCounts ;
8079 this .hostScaler = hostScaler ;
8180 this .taskLauncher = taskLauncher ;
8281 this .sqsJobQueueUrl = getSqsJobQueueUrl (instanceProperties , compactionTask );
83- this .compactionTask = compactionTask ;
8482 }
8583
8684 public static RunDataProcessingTasks createRunDataProcessingTasks (InstanceProperties instanceProperties , EcsClient ecsClient , AutoScalingClient asClient , Ec2Client ec2Client ,
@@ -92,12 +90,11 @@ public static RunDataProcessingTasks createRunDataProcessingTasks(InstanceProper
9290 return new RunDataProcessingTasks (instanceProperties ,
9391 () -> ECSTaskCount .getNumPendingAndRunningTasks (getClusterName (instanceProperties , compactionTask ), ecsClient ),
9492 EC2Scaler .create (instanceProperties , asClient , ec2Client ),
95- (numberOfTasks , checkAbort ) -> launchTasks (ecsClient , instanceProperties , numberOfTasks , checkAbort ),
96- compactionTask );
93+ (numberOfTasks , checkAbort ) -> launchTasks (ecsClient , instanceProperties , numberOfTasks , checkAbort ));
9794 }
9895
9996 public static RunDataProcessingTasks createForCompactions (InstanceProperties instanceProperties , TaskCounts taskCounts , CompactionTaskHostScaler hostScaler , TaskLauncher taskLauncher ) {
100- return new RunDataProcessingTasks (instanceProperties , taskCounts , hostScaler , taskLauncher , true );
97+ return new RunDataProcessingTasks (instanceProperties , taskCounts , hostScaler , taskLauncher );
10198 }
10299
103100 public static RunDataProcessingTasks createForCompactions (InstanceProperties instanceProperties , EcsClient ecsClient , AutoScalingClient asClient , Ec2Client ec2Client ) {
0 commit comments