текущая транзакция прервана ошибка при вызове Postgres из разных функций

Question

У меня есть лямбда-функция, которая содержит несколько функций, каждая из которых сделает несколько запросов к базе данных Postgresql, но получит «текущая транзакция прервана, команды игнорируются до конца блока транзакции \ n» ошибка

Внутри файла лямбда-функции структура имеет вид:

con=get_pg_connection()
cur=con.cursor()

def create_table():
   cur.execute('some query')
   con.commit()
def cast_type():
   cur.execute('some query')
   con.commit()

def insert_data():
   create_table()
   cast_type()
   cur.execute('some query')
   con.commit()

Я определяю соединение вне функций, а третья функция вызывает две другие. Теперь первые две функции получат сообщение об ошибке:

"errorType": "InternalError", "errorMessage": "current transaction is aborted, commands ignored until end of transaction block\n" 

Посоветуйте, пожалуйста, как мне это исправить, спасибо