dlt.helpers.studio.app

home

@app.cell(hide_code=True)
def home(dlt_all_pipelines: List[Dict[str, Any]],
         dlt_pipeline_select: mo.ui.multiselect, dlt_pipelines_dir: str)

View source on GitHub

Displays the welcome page with the pipeline select widget, will only display pipeline title if a pipeline is selected

section_sync_status

@app.cell(hide_code=True)
def section_sync_status(dlt_pipeline: dlt.Pipeline,
                        dlt_section_sync_switch: mo.ui.switch)

View source on GitHub

Returns the status of the pipeline

section_overview

@app.cell(hide_code=True)
def section_overview(dlt_pipeline: dlt.Pipeline,
                     dlt_section_overview_switch: mo.ui.switch)

View source on GitHub

Overview page of currently selected pipeline

section_schema

@app.cell(hide_code=True)
def section_schema(dlt_config: StudioConfiguration, dlt_pipeline: dlt.Pipeline,
                   dlt_schema_show_child_tables: mo.ui.switch,
                   dlt_schema_show_custom_hints: mo.ui.switch,
                   dlt_schema_show_dlt_columns: mo.ui.switch,
                   dlt_schema_show_dlt_tables: mo.ui.switch,
                   dlt_schema_show_other_hints: mo.ui.switch,
                   dlt_schema_show_type_hints: mo.ui.switch,
                   dlt_schema_table_list: mo.ui.table,
                   dlt_section_schema_switch: mo.ui.switch)

View source on GitHub

Show schema of the currently selected pipeline

section_browse_data_table_list

@app.cell(hide_code=True)
def section_browse_data_table_list(
        dlt_cache_query_results: mo.ui.switch,
        dlt_data_table_list: mo.ui.table, dlt_pipeline: dlt.Pipeline,
        dlt_restrict_to_last_1000: mo.ui.switch,
        dlt_schema_show_child_tables: mo.ui.switch,
        dlt_schema_show_dlt_tables: mo.ui.switch,
        dlt_schema_show_row_counts: mo.ui.switch,
        dlt_section_browse_data_switch: mo.ui.switch)

View source on GitHub

Show data of the currently selected pipeline

section_browse_data_query_result

@app.cell(hide_code=True)
def section_browse_data_query_result(
        dlt_data_table_list: mo.ui.table, dlt_pipeline: dlt.Pipeline,
        dlt_query_editor: mo.ui.code_editor,
        dlt_run_query_button: mo.ui.run_button,
        dlt_section_browse_data_switch: mo.ui.switch,
        dlt_cache_query_results: mo.ui.switch, dlt_get_last_query_result,
        dlt_set_last_query_result, dlt_set_query_cache, dlt_get_query_cache)

View source on GitHub

Execute the query in the editor

section_browse_data_query_history

@app.cell(hide_code=True)
def section_browse_data_query_history(
        dlt_pipeline: dlt.Pipeline, dlt_query_history_table: mo.ui.table,
        dlt_section_browse_data_switch: mo.ui.switch,
        dlt_cache_query_results: mo.ui.switch)

View source on GitHub

Show the query history

section_state

@app.cell(hide_code=True)
def section_state(dlt_pipeline: dlt.Pipeline,
                  dlt_section_state_switch: mo.ui.switch)

View source on GitHub

Show state of the currently selected pipeline

section_trace

@app.cell(hide_code=True)
def section_trace(dlt_pipeline: dlt.Pipeline,
                  dlt_section_trace_switch: mo.ui.switch,
                  dlt_trace_steps_table: mo.ui.table,
                  dlt_config: StudioConfiguration)

View source on GitHub

Show last trace of the currently selected pipeline

section_loads

@app.cell(hide_code=True)
def section_loads(dlt_config: StudioConfiguration,
                  dlt_cache_query_results: mo.ui.switch,
                  dlt_pipeline: dlt.Pipeline,
                  dlt_restrict_to_last_1000: mo.ui.switch,
                  dlt_section_loads_switch: mo.ui.switch)

View source on GitHub

Show loads of the currently selected pipeline

section_loads_results

@app.cell(hide_code=True)
def section_loads_results(dlt_loads_table: mo.ui.table,
                          dlt_pipeline: dlt.Pipeline,
                          dlt_section_loads_switch: mo.ui.switch)

View source on GitHub

Show details of the currently selected load

section_ibis_backend

@app.cell(hide_code=True)
def section_ibis_backend(dlt_pipeline: dlt.Pipeline,
                         dlt_section_ibis_browser_switch: mo.ui.switch)

View source on GitHub

Connects to ibis backend and makes it available in the datasources panel

utils_discover_pipelines

@app.cell(hide_code=True)
def utils_discover_pipelines(mo_cli_arg_pipelines_dir: str,
                             mo_cli_arg_pipeline: str,
                             mo_query_var_pipeline_name: str)

View source on GitHub

Discovers local pipelines and returns a multiselect widget to select one of the pipelines

utils_caches_and_state

@app.cell(hide_code=True)
def utils_caches_and_state(dlt_cache_query_results: mo.ui.switch,
                           dlt_pipeline: dlt.Pipeline)

View source on GitHub

Purge caches of the currently selected pipeline

ui_controls

@app.cell(hide_code=True)
def ui_controls(mo_cli_arg_with_test_identifiers: bool)

View source on GitHub

Control elements for various parts of the app

ui_primary_controls

@app.cell(hide_code=True)
def ui_primary_controls(dlt_pipeline: dlt.Pipeline,
                        dlt_schema_show_child_tables: mo.ui.switch,
                        dlt_schema_show_dlt_tables: mo.ui.switch,
                        dlt_schema_show_row_counts: mo.ui.switch,
                        dlt_section_browse_data_switch: mo.ui.switch,
                        dlt_section_schema_switch: mo.ui.switch,
                        dlt_section_trace_switch: mo.ui.switch,
                        dlt_config: StudioConfiguration)

View source on GitHub

Helper cell for creating certain controls based on selected sections

utils_cli_args_and_query_vars_config

@app.cell(hide_code=True)
def utils_cli_args_and_query_vars_config()

View source on GitHub

Prepare cli args as globals for the following cells