fixed formatting

Author: jcstorms1

aws/logs_monitoring/enhanced_lambda_metrics.py

@@ -41,8 +41,10 @@
     + r"Max\s+Memory\s+Used:\s+(?P<{}>\d+)\s+MB".format(MAX_MEMORY_USED_METRIC_NAME)
 )
 
-#Pull memorysize tag and cold start from report
-TAGS_TO_PARSE_FROM_REPORT = [MEMORY_ALLOCATED_FIELD_NAME]
+# Pull memorysize tag and cold start from report
+TAGS_TO_PARSE_FROM_REPORT = [
+    MEMORY_ALLOCATED_FIELD_NAME,
+]
 
 METRICS_TO_PARSE_FROM_REPORT = [
     DURATION_METRIC_NAME,
@@ -184,7 +186,8 @@ def submit_to_dd(self):
         if not timestamp:
             timestamp = time()
 
-        log.debug("Submitting metric {} {} {}".format(self.name, self.value, self.tags))
+        log.debug("Submitting metric {} {} {}".format(
+            self.name, self.value, self.tags))
         lambda_stats.distribution(
             self.name, self.value, timestamp=timestamp, tags=self.tags
         )
@@ -244,7 +247,8 @@ def get_dd_tag_string_from_aws_dict(aws_key_value_tag_dict):
         key:value colon-separated string built from the dict
             ex: "creator:swf"
     """
-    key = sanitize_aws_tag_string(aws_key_value_tag_dict["Key"], remove_colons=True)
+    key = sanitize_aws_tag_string(
+        aws_key_value_tag_dict["Key"], remove_colons=True)
     value = sanitize_aws_tag_string(aws_key_value_tag_dict.get("Value"))
     # Value is optional in DD and AWS
     if not value:
@@ -290,17 +294,21 @@ def build_tags_by_arn_cache():
         tags_by_arn_cache (dict<str, str[]>): each Lambda's tags in a dict keyed by ARN
     """
     tags_by_arn_cache = {}
-    get_resources_paginator = resource_tagging_client.get_paginator("get_resources")
+    get_resources_paginator = resource_tagging_client.get_paginator(
+        "get_resources")
 
     try:
         for page in get_resources_paginator.paginate(
-            ResourceTypeFilters=[GET_RESOURCES_LAMBDA_FILTER], ResourcesPerPage=100
+            ResourceTypeFilters=[
+                GET_RESOURCES_LAMBDA_FILTER], ResourcesPerPage=100
         ):
             lambda_stats.distribution(
-                "{}.get_resources_api_calls".format(ENHANCED_METRICS_NAMESPACE_PREFIX),
+                "{}.get_resources_api_calls".format(
+                    ENHANCED_METRICS_NAMESPACE_PREFIX),
                 1,
             )
-            page_tags_by_arn = parse_get_resources_response_for_tags_by_arn(page)
+            page_tags_by_arn = parse_get_resources_response_for_tags_by_arn(
+                page)
             tags_by_arn_cache.update(page_tags_by_arn)
 
     except ClientError:
@@ -445,7 +453,7 @@ def parse_metrics_from_report_log(report_log_line):
     metrics = []
     tags = []
 
-    #loop is to account for adding cold start 
+    # loop is to account for adding cold start
     for tag in TAGS_TO_PARSE_FROM_REPORT:
         tags.append(tag + ':' + regex_match.group(tag))
 
@@ -466,13 +474,14 @@ def parse_metrics_from_report_log(report_log_line):
         metrics.append(dd_metric)
 
     estimated_cost_metric_point = DatadogMetricPoint(
-        "{}.{}".format(ENHANCED_METRICS_NAMESPACE_PREFIX, ESTIMATED_COST_METRIC_NAME),
+        "{}.{}".format(ENHANCED_METRICS_NAMESPACE_PREFIX,
+                       ESTIMATED_COST_METRIC_NAME),
         calculate_estimated_cost(
             float(regex_match.group(BILLED_DURATION_METRIC_NAME)),
             float(regex_match.group(MEMORY_ALLOCATED_FIELD_NAME)),
         ),
     )
-    
+
     if tags:
         estimated_cost_metric_point.add_tags(tags)