async def METHOD_NAME(self, source: str) -> None:
    def c1() -> None:
        with self._conn, closing(self._conn.cursor()) as cursor:
            cursor.execute(sql("insert", "source"), {"name": source})
    async with self._lock:
        self._ex.submit(c1)