feat: remove redundant "started." messages from progress output (#2440)

Follow-up to
#2419
Thank you for opening a Pull Request! Before submitting your PR, there
are a few things you can do to make sure it goes smoothly:
- [ ] Make sure to open an issue as a
[bug/issue](https://github.com/googleapis/python-bigquery-dataframes/issues/new/choose)
before writing your code! That way we can discuss the change, evaluate
designs, and agree on the general idea
- [ ] Ensure the tests and linter pass
- [ ] Code coverage does not decrease (if any source code was changed)
- [ ] Appropriate docs were updated (if necessary)
Context: b/479944983 🦕

Author: tswast

bigframes/formatting_helpers.py

@@ -27,8 +27,6 @@
 importhumanize
 
 ifTYPE_CHECKING:
-fromIPythonimportdisplay
-
 importbigframes.core.events
 
 GenericJob=Union[
@@ -134,16 +132,14 @@ def repr_query_job_html(query_job: Optional[bigquery.QueryJob]):
 returnres
 
 
-current_display: Optional[display.HTML] =None
 current_display_id: Optional[str] =None
-previous_display_html: str=""
 
 
 defprogress_callback(
 event: bigframes.core.events.Event,
 ):
 """Displays a progress bar while the query is running"""
-globalcurrent_display, current_display_id, previous_display_html
+globalcurrent_display_id
 
 try:
 importbigframes._config
@@ -162,59 +158,44 @@ def progress_callback(
 ifprogress_bar=="notebook":
 importIPython.displayasdisplay
 
-if (
-isinstance(event, bigframes.core.events.ExecutionStarted)
-orcurrent_displayisNone
-orcurrent_display_idisNone
- ):
-previous_display_html=""
-current_display_id=str(random.random())
-current_display=display.HTML("Starting.")
-display.display(
-current_display,
-display_id=current_display_id,
- )
+display_html=None
+
+ifisinstance(event, bigframes.core.events.ExecutionStarted):
+# Start a new context for progress output.
+current_display_id=None
+
+elifisinstance(event, bigframes.core.events.BigQuerySentEvent):
+display_html=render_bqquery_sent_event_html(event)
 
-ifisinstance(event, bigframes.core.events.BigQuerySentEvent):
-previous_display_html=render_bqquery_sent_event_html(event)
-display.update_display(
-display.HTML(previous_display_html),
-display_id=current_display_id,
- )
 elifisinstance(event, bigframes.core.events.BigQueryRetryEvent):
-previous_display_html=render_bqquery_retry_event_html(event)
-display.update_display(
-display.HTML(previous_display_html),
-display_id=current_display_id,
- )
+display_html=render_bqquery_retry_event_html(event)
+
 elifisinstance(event, bigframes.core.events.BigQueryReceivedEvent):
-previous_display_html=render_bqquery_received_event_html(event)
-display.update_display(
-display.HTML(previous_display_html),
-display_id=current_display_id,
- )
+display_html=render_bqquery_received_event_html(event)
+
 elifisinstance(event, bigframes.core.events.BigQueryFinishedEvent):
-previous_display_html=render_bqquery_finished_event_html(event)
-display.update_display(
-display.HTML(previous_display_html),
-display_id=current_display_id,
- )
-elifisinstance(event, bigframes.core.events.ExecutionFinished):
-ifprevious_display_html:
+display_html=render_bqquery_finished_event_html(event)
+
+elifisinstance(event, bigframes.core.events.SessionClosed):
+display_html=f"Session {event.session_id} closed."
+
+ifdisplay_html:
+ifcurrent_display_id:
 display.update_display(
-display.HTML(f"✅ Completed. {previous_display_html}"),
+display.HTML(display_html),
+display_id=current_display_id,
+ )
+else:
+current_display_id=str(random.random())
+display.display(
+display.HTML(display_html),
 display_id=current_display_id,
  )
 
-elifisinstance(event, bigframes.core.events.SessionClosed):
-display.update_display(
-display.HTML(f"Session {event.session_id} closed."),
-display_id=current_display_id,
- )
 elifprogress_bar=="terminal":
-ifisinstance(event, bigframes.core.events.ExecutionStarted):
-print("Starting execution.")
-elifisinstance(event, bigframes.core.events.BigQuerySentEvent):
+message=None
+
+ifisinstance(event, bigframes.core.events.BigQuerySentEvent):
 message=render_bqquery_sent_event_plaintext(event)
 print(message)
 elifisinstance(event, bigframes.core.events.BigQueryRetryEvent):
@@ -226,8 +207,6 @@ def progress_callback(
 elifisinstance(event, bigframes.core.events.BigQueryFinishedEvent):
 message=render_bqquery_finished_event_plaintext(event)
 print(message)
-elifisinstance(event, bigframes.core.events.ExecutionFinished):
-print("Execution done.")
 
 
 defwait_for_job(job: GenericJob, progress_bar: Optional[str] =None):