from typing import List

from airflow.providers.mysql.hooks.mysql import MySqlHook


def get_records_from_db(hook: MySqlHook, sql: str, parameters=None) -> List[dict]:
    return (
        hook.get_pandas_df(sql, parameters)
        .apply(lambda x: x.astype(str) if x.dtype == "datetime64[ns]" else x)
        .to_dict("records")
    )