Class DiffEntry

python/pathway/tests/utils.py:174–205

@dataclass(order=True)
class DiffEntry:
    key: api.Pointer
    order: int
    insertion: bool
    row: dict[str, api.Value]

    @staticmethod
    def create(
        pk_table: pw.Table,
        pk_columns: dict[str, api.Value],
        order: int,
        insertion: bool,
        row: dict[str, api.Value],
        instance: api.Value | None = None,
    ) -> DiffEntry:
        key = DiffEntry.create_id_from(pk_table, pk_columns, instance=instance)
        return DiffEntry(key, order, insertion, row)

    def final_cleanup_entry(self):
        return DiffEntry(self.key, self.order + 1, False, self.row)

    @staticmethod
    def create_id_from(
        pk_table: pw.Table,
        pk_columns: dict[str, api.Value],
        instance: api.Value | None = None,
    ) -> api.Pointer:
        values = list(pk_columns.values())
        if instance is None:
            return api.ref_scalar(*values)
        else:
            return api.ref_scalar_with_instance(*values, instance=instance)


# This class is an abstract subclass of OnChangeCallback, which takes a list of entries