dlt.destinations.utils
get_resource_for_adapter
def get_resource_for_adapter(data: Any) -> DltResource
Helper function for adapters. Wraps data in a DltResource if it's not a DltResource already.
Alternatively if data is a DltSource, throws an error if there are multiple resource in the source
or returns the single resource if available.
info_schema_null_to_bool
def info_schema_null_to_bool(v: str) -> bool
Converts INFORMATION SCHEMA truth values to Python bool
parse_db_data_type_str_with_precision
def parse_db_data_type_str_with_precision(
db_type: str) -> Tuple[str, Optional[int], Optional[int]]
Parses a db data type with optional precision or precision and scale information
get_pipeline_state_query_columns
def get_pipeline_state_query_columns() -> TTableSchema
We get definition of pipeline state table without columns we do not need for the query
get_deterministic_temp_table_name
def get_deterministic_temp_table_name(table_name: str, op: str) -> str
Returns table name suitable for deterministic temp table. Such table will survive disconnects and is supposed to be dropped before being filled again so we need deterministic name with very low collision prob with "data" tables