Convert directory fbcode/measurement to use the Ruff Formatter

fbpcp/mapper/aws.py

@@ -198,7 +198,7 @@ def map_ec2ippermission_to_firewallrule(ip_permission: Dict[str, Any]) -> Firewa
 
 
 def map_ec2securitygroup_to_firewallruleset(
-    security_group: Dict[str, Any]
+    security_group: Dict[str, Any],
 ) -> FirewallRuleset:
     id = security_group["GroupId"]
     vpc_id = security_group["VpcId"]

fbpcp/service/pce_aws.py

@@ -43,7 +43,6 @@ def get_pce(
         return PCE(pce_id, self.region, pce_network, pce_compute)
 
     def _get_network(self, pce_id: str) -> PCENetwork:
-
         tags = {PCE_ID_KEY: pce_id}
         vpcs = self.ec2_gateway.describe_vpcs(tags=tags)
         vpc = vpcs[0] if vpcs else None

onedocker/mapper/aws.py

@@ -13,7 +13,7 @@
 
 
 def map_dynamodbitem_to_packagemetadata(
-    dynamodb_item: Dict[str, Any]
+    dynamodb_item: Dict[str, Any],
 ) -> PackageMetadata:
     measurements = {
         MeasurementType(key): value

onedocker/script/cli/onedocker_cli.py

@@ -220,7 +220,15 @@ def _build_onedocker_service(
 
 
 def main() -> None:
-    global container_svc, onedocker_svc, onedocker_repo_svc, log_svc, logger, task_definition, repository_path, storage_svc
+    global \
+        container_svc, \
+        onedocker_svc, \
+        onedocker_repo_svc, \
+        log_svc, \
+        logger, \
+        task_definition, \
+        repository_path, \
+        storage_svc
     s = schema.Schema(
         {
             "upload": bool,

onedocker/script/runner/onedocker_runner.py

@@ -24,6 +24,7 @@
     --opa_workflow_path=<workflow_path>                     Set path of a pre-defined workflow for OneDocker Plugin Architecture usage. When set, OPA exeuction according to the predefined workflow is triggered.
     --verbose                                               Set logging level to DEBUG.
 """
+
 import logging
 import os
 import resource

pce/gateway/ec2.py

@@ -57,7 +57,6 @@ def describe_vpc_peering_connections_with_accepter_vpc_id(
     def accept_vpc_peering_connection(
         self, vpc_peering_connection_id: str, vpc_id: str
     ) -> Optional[VpcPeering]:
-
         response = self.client.accept_vpc_peering_connection(
             VpcPeeringConnectionId=vpc_peering_connection_id
         )
@@ -72,7 +71,6 @@ def accept_vpc_peering_connection(
     def create_route(
         self, route_table_id: str, vpc_peering_connection_id: str, dest_cidr: str
     ) -> bool:
-
         response = self.client.create_route(
             RouteTableId=route_table_id,
             DestinationCidrBlock=dest_cidr,
@@ -85,7 +83,6 @@ def create_route(
     def replace_route(
         self, route_table_id: str, vpc_peering_connection_id: str, dest_cidr: str
     ) -> None:
-
         self.client.replace_route(
             RouteTableId=route_table_id,
             DestinationCidrBlock=dest_cidr,

pce/validator/validator.py

@@ -21,7 +21,6 @@
     --skip-step=<skip-step> [+]     name of a validation step to be skipped, eg vpc_peering
 """
 
-
 import logging
 import sys
 from enum import Enum
@@ -58,7 +57,6 @@ def get_arn(
     key_id: str,
     key_data: str,
 ) -> str:
-
     sts_gateway: STSGateway = STSGateway(region, key_id, key_data, None)
     return sts_gateway.get_caller_arn()