def update_cmd()

in train/pantheon_env.py [0:0]

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

def update_cmd(cmd, flags, thread_id, job_id=None):
    if flags.mode == "train":
        schemes = "mvfst_rl"
        run_times = 1
        assert job_id is not None
    else:  # test mode
        schemes = " ".join(get_test_schemes(flags))
        run_times = flags.test_runs_per_job
        assert job_id is None  # not currently supported in test mode
        job_id = -1

    extra_sender_args = " ".join(
        [
            "--cc_env_mode={}".format(flags.cc_env_mode),
            "--cc_env_rpc_address={}".format(flags.server_address),
            "--cc_env_actor_id={}".format(thread_id),
            "--cc_env_job_id={}".format(job_id),
            "--cc_env_model_file={}".format(flags.traced_model),
            "--cc_env_agg={}".format(flags.cc_env_agg),
            "--cc_env_time_window_ms={}".format(flags.cc_env_time_window_ms),
            "--cc_env_fixed_window_size={}".format(flags.cc_env_fixed_window_size),
            "--cc_env_use_state_summary={}".format(flags.cc_env_use_state_summary),
            "--cc_env_history_size={}".format(flags.cc_env_history_size),
            "--cc_env_norm_ms={}".format(flags.cc_env_norm_ms),
            "--cc_env_norm_bytes={}".format(flags.cc_env_norm_bytes),
            "--cc_env_actions={}".format(",".join(flags.cc_env_actions)),
            "--cc_env_reward_log_ratio={}".format(flags.cc_env_reward_log_ratio),
            "--cc_env_reward_throughput_factor={}".format(
                flags.cc_env_reward_throughput_factor
            ),
            "--cc_env_reward_throughput_log_offset={}".format(
                flags.cc_env_reward_throughput_log_offset
            ),
            "--cc_env_reward_delay_factor={}".format(flags.cc_env_reward_delay_factor),
            "--cc_env_reward_delay_log_offset={}".format(
                flags.cc_env_reward_delay_log_offset
            ),
            "--cc_env_reward_packet_loss_factor={}".format(
                flags.cc_env_reward_packet_loss_factor
            ),
            "--cc_env_reward_packet_loss_log_offset={}".format(
                flags.cc_env_reward_packet_loss_log_offset
            ),
            "--cc_env_reward_max_delay={}".format(flags.cc_env_reward_max_delay),
            "--cc_env_fixed_cwnd={}".format(flags.cc_env_fixed_cwnd),
            "--cc_env_min_rtt_window_length_us={}".format(
                flags.cc_env_min_rtt_window_length_us
            ),
            "-v={}".format(flags.loglevel),
        ]
    )
    return shlex.split(cmd) + [
        "--schemes={}".format(schemes),
        "--run-times={}".format(run_times),
        '--extra-sender-args="{}"'.format(extra_sender_args),
    ]