файл db
try:
    db = psycopg2.connect("dbname='domain_expire' user='test' password='matt17'")
    cursor = db.cursor()
    cursor.execute("CREATE TABLE domains (id serial PRIMARY KEY, "
                                             "dname varchar(255) UNIQUE NULL, "
                                             "period integer DEFAULT 0,"
                                             "status integer DEFAULT 0);")

    cursor.execute("CREATE TABLE sessions (id serial PRIMARY KEY, "
                                       "started timestamp, "
                                       "finished timestamp, "
                                       "status integer DEFAULT 0);")

    cursor.execute("CREATE TABLE result (id serial PRIMARY KEY, "
                                        "session_id integer references sessions(id), "
                                        "domain_id integer references domains(id), "
                                        "dmn_created timestamp, "
                                        "dmn_updated timestamp, "
                                        "dmn_expired timestamp, "
                                        "answer varchar(255) NULL, "
                                        "checked integer DEFAULT 0);")

    cursor.execute("CREATE TABLE statuses (id serial PRIMARY KEY, "
                                          "name text UNIQUE NULL);")

    cursor.execute("CREATE TABLE result_status (result_id integer references result(id), "
                                            "status_id integer references statuses(id));")

    db.commit()
    cursor.close()
except psycopg2.Error as err:
    print("Connection error: {}".format(err))


def insert_statuses(status):
    try:
        cursor.execute("INSERT INTO statuses (name) VALUES ({});".format(status))
        db.commit()
        cursor.close()
    except psycopg2.Error as err:
        print(err.pgerror)
        print(err.diag.message_primary)
        print("Connection error: {}".format(err))

def select_statuses(get_params, column, value):
    try:
        cursor.execute("SELECT {0} FROM statuses WHERE {1}={2};".format(get_params, column, value))
        status = cursor.fetchall()
        if status is not None:
            return status
        else:
            return False
        db.commit()
        cursor.close()
    except psycopg2.Error as err:
        print("Connection error: {}".format(err))

файл worker
def get_whois():
    try:
        url = requests.get("https://api.ps.kz/kzdomain/domain-whois?username=name&password=pass&input_format=json&output_format=json&input_data={%20%22dname%22:%20%22kapital.kz%22,%20%22contact_whois%22:%201}")
        if url.status_code == 200:
            whois = url.json()
        else:
            print(url.status_code)

        if whois is not None:
            for status in whois["answer"]["statuses"]["status"]:
                status_id = db.select_statuses(get_params='id', column='name', value='status')
                if status_id is None:
                    db.insert_statuses(status)

выводит
Connection error: ОШИБКА:  текущая транзакция прервана, команды до конца блока транзакции игнорируются

ОШИБКА:  текущая транзакция прервана, команды до конца блока транзакции игнорируются

текущая транзакция прервана, команды до конца блока транзакции игнорируются
Connection error: ОШИБКА:  текущая транзакция прервана, команды до конца блока транзакции игнорируются

Connection error: ОШИБКА:  текущая транзакция прервана, команды до конца блока транзакции игнорируются

ОШИБКА:  текущая транзакция прервана, команды до конца блока транзакции игнорируются

текущая транзакция прервана, команды до конца блока транзакции игнорируются
Connection error: ОШИБКА:  текущая транзакция прервана, команды до конца блока транзакции игнорируются