(self, start_time: float, end_time: float)
| 454 | return df |
| 455 | |
| 456 | def summary(self, start_time: float, end_time: float) -> pd.DataFrame: |
| 457 | if len(self.session_summaries) == 0 and len(self.sessions) == 0: |
| 458 | return pd.DataFrame() |
| 459 | |
| 460 | df = pd.concat( |
| 461 | [s for s in self.session_summaries] + [s.summary() for s in self.sessions] |
| 462 | ) |
| 463 | pending_queries = len([s for s in self.sessions if s.has_unfinished_request]) |
| 464 | start_time = max(self.start_time, start_time) |
| 465 | end_time = min(end_time, df["finish_time"].max()) |
| 466 | |
| 467 | df = UserSessionManager.ProcessSummary( |
| 468 | df, start_time, end_time, pending_queries |
| 469 | ) |
| 470 | return df |
| 471 | |
| 472 | |
| 473 | def parse_arguments() -> WorkloadConfig: |
no test coverage detected