flytekit.deck.deck

Directory

Classes

Methods

Variables

Methods

generate_time_table()

def generate_time_table(
    data: dict,
) -> str

get_deck_template()

def get_deck_template()

flytekit.deck.deck.Deck

Deck enable users to get customizable and default visibility into their tasks.

Deck contains a list of renderers (FrameRenderer, MarkdownRenderer) that can generate a html file. For example, FrameRenderer can render a DataFrame as an HTML table, MarkdownRenderer can convert Markdown string to HTML

Flyte context saves a list of deck objects, and we use renderers in those decks to render the data and create an HTML file when those tasks are executed

Each task has a least three decks (input, output, default). Input/output decks are used to render tasks’ input/output data, and the default deck is used to render line plots, scatter plots or Markdown text. In addition, users can create new decks to render their data with custom renderers.

iris_df = px.data.iris()

@task()
def t1() -> str:
    md_text = '#Hello Flyte##Hello Flyte###Hello Flyte'
    m = MarkdownRenderer()
    s = BoxRenderer("sepal_length")
    deck = flytekit.Deck("demo", s.to_html(iris_df))
    deck.append(m.to_html(md_text))
    default_deck = flytekit.current_context().default_deck
    default_deck.append(m.to_html(md_text))
    return md_text


# Use Annotated to override default renderer
@task()
def t2() -> Annotated[pd.DataFrame, TopFrameRenderer(10)]:
    return iris_df

class Deck(
    name: str,
    html: typing.Optional[str],
    auto_add_to_deck: bool,
)

Methods

append()

def append(
    html: str,
) -> Deck

publish()

def publish()

Properties

flytekit.deck.deck.TimeLineDeck

The TimeLineDeck class is designed to render the execution time of each part of a task. Unlike deck class, the conversion of data to HTML is delayed until the html property is accessed. This approach is taken because rendering a timeline graph with partial data would not provide meaningful insights. Instead, the complete data set is used to create a comprehensive visualization of the execution time of each part of the task.

class TimeLineDeck(
    name: str,
    html: typing.Optional[str],
    auto_add_to_deck: bool,
)

Methods

append()

def append(
    html: str,
) -> Deck

append_time_info()

def append_time_info(
    info: dict,
)

publish()

def publish()

Properties