()
| 894 | # helpful to understand the structure. |
| 895 | |
| 896 | def update_runtime_info(): |
| 897 | required_mem = min(mem_limit, impala.min_impalad_mem_mb) |
| 898 | if report.mem_was_spilled: |
| 899 | if ( |
| 900 | query.required_mem_mb_with_spilling is None or |
| 901 | required_mem < query.required_mem_mb_with_spilling |
| 902 | ): |
| 903 | query.required_mem_mb_with_spilling = required_mem |
| 904 | query.solo_runtime_secs_with_spilling = report.runtime_secs |
| 905 | query.solo_runtime_profile_with_spilling = report.profile |
| 906 | elif ( |
| 907 | query.required_mem_mb_without_spilling is None or |
| 908 | required_mem < query.required_mem_mb_without_spilling |
| 909 | ): |
| 910 | query.required_mem_mb_without_spilling = required_mem |
| 911 | query.solo_runtime_secs_without_spilling = report.runtime_secs |
| 912 | assert report.runtime_secs is not None, report |
| 913 | query.solo_runtime_profile_without_spilling = report.profile |
| 914 | |
| 915 | def get_report(desired_outcome=None): |
| 916 | reports_by_outcome = defaultdict(list) |
no test coverage detected