dlt.common.typing
CallableAny
A special callable Any that returns argument but is recognized as Any type by dlt hint checkers
StrAny
immutable, covariant entity
StrStr
immutable, covariant entity
StrStrStr
immutable, covariant entity
TFun
any function
SecretSentinel Objects
class SecretSentinel()
Marks a secret type when part of type annotations
TColumnNames
A string representing a column name or a sequence of
TTableNames
A string representing a table name or a sequence of
TDataItem
A single data item as extracted from data source
TDataItems
A single data item or a list as extracted from the data source
TAnyDateTime
DateTime represented as pendulum/python object, ISO string or unix timestamp
TLoaderFileFormat
known loader file formats
ConfigValueSentinel Objects
class ConfigValueSentinel(NamedTuple)
Class to create singleton sentinel for config and secret injected value
ConfigValue
Config value indicating argument that may be injected by config provider. Evaluates to None when type checking
SecretValue
Secret value indicating argument that may be injected by config provider. Evaluates to None when type checking
SupportsVariant Objects
@runtime_checkable
class SupportsVariant(Protocol, Generic[TVariantBase])
Defines variant type protocol that should be recognized by normalizers
Variant types behave like TVariantBase type (ie. Decimal) but also implement the protocol below that is used to extract the variant value from it.
See Wei
type declaration which returns Decimal or str for values greater than supported by destination warehouse.
SupportsHumanize Objects
class SupportsHumanize(Protocol)
asdict
def asdict() -> DictStrAny
Represents object as dict with a schema loadable by dlt
asstr
def asstr(verbosity: int = 0) -> str
Represents object as human readable string
SocketLike Objects
class SocketLike(Protocol)
send
def send(data: bytes) -> int
Send bytes; return number of bytes sent.
recv
def recv(bufsize: int) -> bytes
Receive up to bufsize
bytes and return them.
close
def close() -> None
Close the socket-like connection.
settimeout
def settimeout(timeout: float) -> None
Set the timeout (in seconds) for send/recv operations.