Function table_to_dicts

python/pathway/debug/__init__.py:60–89

Runs the computations needed to get the contents of the Pathway Live Data Framework Table and converts it to a dictionary representation, where each column is mapped to its respective values. Args: table (Table): The Pathway Live Data Framework Table to be converted. **

(
    table: Table,
    **kwargs,
)

def table_to_dicts(
    table: Table,
    **kwargs,
) -> tuple[list[api.Pointer], dict[str, dict[api.Pointer, api.Value]]]:
    """
    Runs the computations needed to get the contents of the Pathway Live Data Framework Table and converts it
    to a dictionary representation, where each column is mapped to its respective values.

    Args:
        table (Table): The Pathway Live Data Framework Table to be converted.
        **kwargs: Additional keyword arguments to customize the behavior of the function.
                  - terminate_on_error (bool): If True, the function will terminate execution upon
                  encountering an error during the squashing of updates. Defaults to True.

    Returns:
        tuple: A tuple containing two elements: 1) list of keys (pointers) that represent
        the rows in the table, and 2) a dictionary where each key is a column name,
        and the value is another dictionary mapping row keys (pointers) to their respective
        values in that column.
    """
    captured = _compute_tables(table, **kwargs)[0]
    output_data = api.squash_updates(
        captured, terminate_on_error=kwargs.get("terminate_on_error", True)
    )
    keys = list(output_data.keys())
    columns = {
        name: {key: output_data[key][index] for key in keys}
        for index, name in enumerate(table._columns.keys())
    }
    return keys, columns


@functools.total_ordering