Проблема решена!
У меня было так:
def get_pool(endpoint, database):
....
pool = ydb.SessionPool(driver)
result = pool.retry_operation_sync(execute_query)
return result
def execute_query(session):
return session.transaction().execute(')
Даёт ошибку connection failed и всё тут. Посмотрел на код в ответе, перенёс функцию execute_query(session) внутрь главной и всё заработало!
Спасибо!