nvidia-efa-ami_base/cloudwatch/efa/efa-to-cw.py [66:89]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        metric_shard.append(a)
    return metric_shard

def gzip_request_body(request, **kwargs):
    gzipped_body = gzip.compress(request.body)
    request.headers.add_header('Content-Encoding', 'gzip')
    request.data = gzipped_body

def logResults(metric_shard):
    if (PUSH_TO_CW):
#        event_system.register('before-sign.cloudwatch.PutMetricData', gzip_request_body)
        cloudwatch.put_metric_data(
            Namespace=my_NameSpace,
            MetricData=metric_shard
        )

def main():
        while True:
            PUSH_TO_CW = True
            accel_metric_list=[]
            accel_metric_shard=subprocess.check_output(BINARY_PATH, universal_newlines=True)
            accel_metric_list=accel_metric_shard.splitlines()
            for accel in range(len(accel_metric_list)):
                d=json.loads(accel_metric_list[accel])
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



nvidia-efa-ami_base/cloudwatch/nvidia/accel-to-cw.py [87:111]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        metric_shard.append(a)
    return metric_shard

def gzip_request_body(request, **kwargs):
    gzipped_body = gzip.compress(request.body)
    request.headers.add_header('Content-Encoding', 'gzip')
    request.data = gzipped_body

def logResults(metric_shard):
    if (PUSH_TO_CW):
#        event_system.register('before-sign.cloudwatch.PutMetricData', gzip_request_body)
        cloudwatch.put_metric_data(
            Namespace=my_NameSpace,
            MetricData=metric_shard
        )


def main():
        while True:
            PUSH_TO_CW = True
            accel_metric_list=[]
            accel_metric_shard=subprocess.check_output(BINARY_PATH, universal_newlines=True)
            accel_metric_list=accel_metric_shard.splitlines()
            for accel in range(len(accel_metric_list)):
                d=json.loads(accel_metric_list[accel])
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -