def METHOD_NAME():
    hook = MagicMock()
    ANOTHER_DB_NAME = "ANOTHER_DB"
    rows = [
        (DB_SCHEMA_NAME, DB_TABLE_NAME.name, "ID", 1, "int4", DB_NAME),
        (DB_SCHEMA_NAME, DB_TABLE_NAME.name, "AMOUNT_OFF", 2, "int4", DB_NAME),
        (DB_SCHEMA_NAME, DB_TABLE_NAME.name, "CUSTOMER_EMAIL", 3, "varchar", DB_NAME),
        (DB_SCHEMA_NAME, DB_TABLE_NAME.name, "STARTS_ON", 4, "timestamp", DB_NAME),
        (DB_SCHEMA_NAME, DB_TABLE_NAME.name, "ENDS_ON", 5, "timestamp", DB_NAME),
        (DB_SCHEMA_NAME, DB_TABLE_NAME.name, "ID", 1, "int4", ANOTHER_DB_NAME),
        (DB_SCHEMA_NAME, DB_TABLE_NAME.name, "AMOUNT_OFF", 2, "int4", ANOTHER_DB_NAME),
        (
            DB_SCHEMA_NAME,
            DB_TABLE_NAME.name,
            "CUSTOMER_EMAIL",
            3,
            "varchar",
            ANOTHER_DB_NAME,
        ),
        (
            DB_SCHEMA_NAME,
            DB_TABLE_NAME.name,
            "STARTS_ON",
            4,
            "timestamp",
            ANOTHER_DB_NAME,
        ),
        (
            DB_SCHEMA_NAME,
            DB_TABLE_NAME.name,
            "ENDS_ON",
            5,
            "timestamp",
            ANOTHER_DB_NAME,
        ),
    ]
    hook.get_conn.return_value.cursor.return_value.fetchall.side_effect = [rows, []]
    source = Source(scheme="bigquery", authority=None, connection_url=None, name=None)
    table_schemas = get_table_schemas(
        hook=hook,
        source=source,
        database=DB_NAME,
        in_query="fake_sql",
        out_query="another_fake_sql",
    )
    assert table_schemas == (
        [
            Dataset.from_table_schema(source, DB_TABLE_SCHEMA, DB_NAME),
            Dataset.from_table_schema(source, DB_TABLE_SCHEMA, ANOTHER_DB_NAME),
        ],
        [],
    )