'Returns a druid connection object for query'

def get_conn(self):

    conn = self.get_connection(self.druid_query_conn_id)
    return PyDruid('http://{conn.host}:{conn.port}'.format(**locals()), conn.extra_dejson.get('endpoint', ''))
