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