def METHOD_NAME(self, data_source):
    connection = clickhouse_driver.connect(
        self.get_connection_url(database=data_source.database)
    )
    query_params = data_source.parameters or {}
    query = (
        data_source.query
        if data_source.query
        else f'select * from {data_source.table} limit 50;'
    )
    df = pandas_read_sql(query, con=connection, params=query_params, adapt_params=True)
    connection.close()
    return df