destinations.utils
ensure_resource
def ensure_resource(data: Any) -> DltResource
Wraps data
in a DltResource if it's not a DltResource already.
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