Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
Qinghao-Hu committed Oct 17, 2022
1 parent 9b9ba89 commit 653c85b
Showing 1 changed file with 9 additions and 9 deletions.
18 changes: 9 additions & 9 deletions simulation/simulator.py
Original file line number Diff line number Diff line change
Expand Up @@ -103,17 +103,17 @@ def main(args):
utils.cluster_concatenate(policy, args.placer, log_dir, args.trace_dir)
else:
utils.cluster_concatenate(args.scheduler, args.placer, log_dir, args.trace_dir)
utils.cluster_analysis(args.placer, log_dir, args.trace_dir)

utils.cluster_analysis(args.placer, log_dir, args.trace_dir)
logger.info(f"Execution Time: {round(time.perf_counter() - code_start, 2)}s")
"""Fast query result"""
sched_label = args.scheduler + "_consolidate"
jct_df = pd.read_csv(f"{log_dir}/jct_avg_consolidate.csv", index_col=0)
jct = jct_df.at["all", sched_label]
que_df = pd.read_csv(f"{log_dir}/que_avg_consolidate.csv", index_col=0)
que = que_df.at["all", sched_label]
logger.info(f"Summary of {args.scheduler}: Avg. JCT {jct}s, Avg. Queue {que}s")

"""Fast query result"""
sched_label = args.scheduler + "_consolidate"
jct_df = pd.read_csv(f"{log_dir}/jct_avg_consolidate.csv", index_col=0)
jct = jct_df.at["all", sched_label]
que_df = pd.read_csv(f"{log_dir}/que_avg_consolidate.csv", index_col=0)
que = que_df.at["all", sched_label]
logger.info(f"Summary of {args.scheduler}: Avg. JCT {jct}s, Avg. Queue {que}s")
logger.info(f"Execution Time: {round(time.perf_counter() - code_start, 2)}s")


if __name__ == "__main__":
Expand Down

0 comments on commit 653c85b

Please sign in to comment.