Could not complete query "select uuid from wos_2017_1.combined_name   where  combined_name = 'xxxxxxx';"
Traceback (most recent call last):
  File "update2017.py", line 1206, in runquery
    result = await con.fetch(query)
  File "/usr/lib/python3/dist-packages/asyncpg/connection.py", line 268, in fetch
    stmt = await self._get_statement(query, timeout)
  File "/usr/lib/python3/dist-packages/asyncpg/connection.py", line 212, in _get_statement
    state = await protocol.prepare(None, query, timeout)
  File "asyncpg/protocol/protocol.pyx", line 140, in prepare      (asyncpg/protocol/protocol.c:55210)
  File "/usr/lib/python3.5/asyncio/futures.py", line 380, in __iter__
yield self  # This tells Task to wait for completion.
  File "/usr/lib/python3.5/asyncio/tasks.py", line 304, in _wakeup
    future.result()
  File "/usr/lib/python3.5/asyncio/futures.py", line 293, in result
raise self._exception
asyncpg.exceptions.DuplicatePreparedStatementError: prepared statement "stmt_7" already exists

$ grep -c  INSERT /tmp/y.log
1006
$ grep -c  SELECT /tmp/y.log
1364
$ grep -ci  UPDATE /tmp/y.log
1044
$ grep -ci  delete /tmp/y.log
2548



    import asyncio,asyncpg

    async def make_pool():
         """Create asyncpg connection pool to database"""

         pool = await asyncpg.create_pool(database='wos',
                                 host = 'localhost',
                                 user = 'xx',
                                 password='xxxxxx',


                     port=5432,
                                 min_size=10,
                                 max_size=50)

         return pool

    async def get_con(pool):
        con = await pool.acquire()
        return con

    async def runquery(query):
        con = await get_con(pool)
        try:
            if query.startswith('delete from') or query.startswith('insert'):
                result = await con.execute(query)
            else:
                result = await con.fetch(query)
        except:
            print('Could not complete query "{}"'.format(query))
            print(traceback.format_exc())
            result = None
            exit(1)
        finally:
            await pool.release(con)
        return result, success