in nvidia-efa-ami_base/cloudwatch/efa/efa-to-cw.py [0:0]
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])
ametric_shard=create_metric_shard(d['Efa_index'],d['Driver'],d['Efa_name'],d['Metrics'])
print(ametric_shard)
logResults(ametric_shard)
sleep(sleep_interval)