Skip to content

Commit

Permalink
Show simple unordered list with pipeline summary
Browse files Browse the repository at this point in the history
  • Loading branch information
sultaniman committed Mar 18, 2024
1 parent c2574d6 commit 5e96f79
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 7 deletions.
5 changes: 0 additions & 5 deletions dlt/helpers/streamlit_app/blocks/pipeline_state.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,15 +2,10 @@
import streamlit as st

from dlt.common.destination.reference import WithStateSync
from dlt.helpers.streamlit_app.widgets import tag
from dlt.pipeline.state_sync import load_pipeline_state_from_destination


def pipeline_state_info(pipeline: dlt.Pipeline) -> None:
st.divider()
tag(pipeline.pipeline_name, label="Pipeline")
tag(pipeline.destination.destination_name, label="Destination")

remote_state = None
with pipeline.destination_client() as client:
if isinstance(client, WithStateSync):
Expand Down
4 changes: 2 additions & 2 deletions dlt/helpers/streamlit_app/widgets/summary.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,8 +11,8 @@ def pipeline_summary(pipeline: dlt.Pipeline) -> None:
st.error("🚨 Cannot load data - SqlClient not available")

schema_names = ", ".join(sorted(pipeline.schema_names))
expander = st.expander("Pipeline info", expanded=True)
expander.markdown(f"""
st.subheader("Pipeline info", divider=True)
st.markdown(f"""
* pipeline name: **{pipeline.pipeline_name}**
* destination: **{str(credentials)}** in **{pipeline.destination.destination_description}**
* dataset name: **{pipeline.dataset_name}**
Expand Down

0 comments on commit 5e96f79

Please sign in to comment.