Method test_exec_summary

tests/query_test/test_observability.py:404–428

Test that the exec summary is populated correctly in every query state

(self)

    assert re.search(r'\n\s+OrderBy Columns:\s+(.*?)\n', result.runtime_profile) is None

  def test_exec_summary(self):
    """Test that the exec summary is populated correctly in every query state"""
    query = "select count(*) from functional.alltypes"
    handle = self.execute_query_async(query,
        {"debug_action": "AC_BEFORE_ADMISSION:SLEEP@1000"})
    # If ExecuteStatement() has completed and the query is paused in the admission control
    # phase, then the coordinator has not started yet and exec_summary should be empty.
    exec_summary = self.client.get_exec_summary(handle)
    assert exec_summary is not None and exec_summary.nodes is None
    # After completion of the admission control phase, the coordinator would have started
    # and we should get a populated exec_summary.
    self.client.wait_for_admission_control(handle)
    exec_summary = self.client.get_exec_summary(handle)
    assert exec_summary is not None and exec_summary.nodes is not None

    self.client.fetch(query, handle)
    exec_summary = self.client.get_exec_summary(handle)
    # After fetching the results and reaching finished state, we should still be able to
    # fetch an exec_summary.
    assert exec_summary is not None and exec_summary.nodes is not None
    # Verify the query is complete.
    assert exec_summary.progress.num_completed_scan_ranges == \
        exec_summary.progress.total_scan_ranges
    assert exec_summary.progress.num_completed_fragment_instances == \
        exec_summary.progress.total_fragment_instances

  def test_exec_summary_in_runtime_profile(self):
    """Test that the exec summary is populated in runtime profile correctly in every