def auroraAdjust()

in src/main/scala/com/twitter/iago/launcher/AuroraMode.scala [194:215]

• 19 lines of code
• 2 McCabe index (conditional complexity)

  def auroraAdjust(feederFlags: Seq[Flag[_]], serverFlags: Seq[Flag[_]]): Unit = {
    missingFlagCheck(auroraRequiredFlagsForAdjust)

    val launcherArgs = flagMapToArgs(
      flagsToFlagMap(List(requestRateF, servicePortF)) +
        (servicePortF.name -> {
          if (servicePortF.isDefined) servicePortF() else ":{{thermos.ports[thrift]}}"
        })
    )

    // call launcher adjust -env.local on server jobs via aurora task run
    val feederAdjustCmd = List(
      "aurora",
      "task",
      "run",
      "--threads",
      "4",
      s"$serverJobPath",
      s"$auroraAdjustLauncherCmd adjust -env.local ${launcherArgs.mkString(" ")}"
    )
    runCmdWithExitOnError(feederAdjustCmd, errorMsg = "Failed to adjust feeder jobs")
  }