Skip to content

Commit 01318e1

Browse files
committed
[CodeStyle] Address linter findings.
1 parent 86e3318 commit 01318e1

File tree

3 files changed

+15
-5
lines changed

3 files changed

+15
-5
lines changed

tests/integration-tests/tests/common/utils.py

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -563,13 +563,19 @@ def get_capacity_reservation_id(request, instance_type, region, count, os):
563563
reservations_ids = []
564564
ec2_client = boto3.client("ec2", region_name=region)
565565
if request.config.getoption("capacity_reservation_id"):
566-
capacity_reservation = ec2_client.describe_capacity_reservations(CapacityReservationIds=[request.config.getoption("capacity_reservation_id")])
566+
capacity_reservation = ec2_client.describe_capacity_reservations(
567+
CapacityReservationIds=[request.config.getoption("capacity_reservation_id")]
568+
)
567569
if capacity_reservation:
568570
reservations_ids.append(
569571
{
570-
"CapacityReservationId": capacity_reservation.get("CapacityReservations", [])[0]["CapacityReservationId"],
572+
"CapacityReservationId": capacity_reservation.get("CapacityReservations", [])[0][
573+
"CapacityReservationId"
574+
],
571575
"TotalInstanceCount": capacity_reservation.get("CapacityReservations", [])[0]["TotalInstanceCount"],
572-
"AvailableInstanceCount": capacity_reservation.get("CapacityReservations", [])[0]["AvailableInstanceCount"],
576+
"AvailableInstanceCount": capacity_reservation.get("CapacityReservations", [])[0][
577+
"AvailableInstanceCount"
578+
],
573579
}
574580
)
575581
else:

tests/integration-tests/tests/efa/test_efa.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ def test_efa(
5858
max_queue_size = 2
5959
p6_b200_capacity_reservation_id = None
6060
if instance == "p6-b200.48xlarge":
61-
capacity_reservations_ids = get_capacity_reservation_id(request,instance, region, max_queue_size, os)
61+
capacity_reservations_ids = get_capacity_reservation_id(request, instance, region, max_queue_size, os)
6262
if capacity_reservations_ids:
6363
p6_b200_capacity_reservation_id = capacity_reservations_ids[0].get("CapacityReservationId")
6464
else:

tests/integration-tests/tests/ultraserver/test_gb200.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,11 @@
4141
def submit_job_imex_status(rce: RemoteCommandExecutor, queue: str, max_nodes: int = 1, ignore_imex_check: bool = False):
4242
logging.info("Submitting job to check IMEX status")
4343
slurm = SlurmCommands(rce)
44-
job_command = "/opt/parallelcluster/shared/nvidia-imex-status.job ignore-imex-check" if ignore_imex_check else "/opt/parallelcluster/shared/nvidia-imex-status.job"
44+
job_command = (
45+
"/opt/parallelcluster/shared/nvidia-imex-status.job ignore-imex-check"
46+
if ignore_imex_check
47+
else "/opt/parallelcluster/shared/nvidia-imex-status.job"
48+
)
4549
job_id = slurm.submit_command_and_assert_job_accepted(
4650
submit_command_args={
4751
"command": job_command,

0 commit comments

Comments
 (0)