apache_beam.runners.interactive.display.display_manager module

Manages displaying pipeline graph and execution status on the frontend.

This module is experimental. No backwards-compatibility guarantees.

class apache_beam.runners.interactive.display.display_manager.DisplayManager(pipeline_proto, pipeline_analyzer, cache_manager, pipeline_graph_renderer)[source]

Bases: object

Manages displaying pipeline graph and execution status on the frontend.

Constructor of DisplayManager.

Parameters:
  • pipeline_proto – (Pipeline proto)
  • pipeline_analyzer – (PipelineAnalyzer) the pipeline analyzer that corresponds to this round of execution. This will provide more detailed informations about the pipeline
  • cache_manager – (interactive_runner.CacheManager) DisplayManager fetches the latest status of pipeline execution by querying cache_manager.
  • pipeline_graph_renderer – (pipeline_graph_renderer.PipelineGraphRenderer) decides how a pipeline graph is rendered.
start_periodic_update()[source]

Start a thread that periodically updates the display.

stop_periodic_update()[source]

Stop periodically updating the display.

update_display(force=False)[source]

Updates display on the frontend.

Retrieves the latest execution status by querying CacheManager and updates display on the fronend. The assumption is that there is only one pipeline in a cell, because it clears up everything in the cell output every update cycle.

Parameters:force – (bool) whether to force updating when no stats change happens.