Source code for superduperdb.backends.ibis.cdc.base

import dataclasses as dc
import typing as t

from superduperdb.base.serializable import Serializable
from superduperdb.cdc.cdc import DBEvent, Packet

TokenType = t.Dict[str, str]


[docs] @dc.dataclass class IbisDBPacket(Packet): """ A base packet to represent message in task queue. """ ids: t.List[str] query: t.Optional[Serializable] = None event_type: DBEvent = DBEvent.insert