Skip to content

Commit fff3dd4

Browse files
committed
Correct spell mistake
1 parent f0d66f5 commit fff3dd4

File tree

1 file changed

+10
-10
lines changed

1 file changed

+10
-10
lines changed

cx_Oracle_async/utils.py

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212
DEFAULT_MAXIMUM_WORKER_NUM = (os.cpu_count() or 1) * 32
1313
DEFAULT_MAXIMUM_WORKER_TIMES = 3
1414

15-
class AsyncCursorWarpper:
15+
class AsyncCursorWrapper:
1616

1717
def __init__(self , loop , thread_pool , cursor):
1818
self._loop = loop
@@ -42,7 +42,7 @@ async def var(self, args):
4242
return await self._loop.run_in_executor(self._thread_pool , self._cursor.var, args)
4343

4444

45-
class AsyncCursorWarpper_context:
45+
class AsyncCursorWrapper_context:
4646

4747
def __init__(self , loop , thread_pool , conn):
4848
self._loop = loop
@@ -51,25 +51,25 @@ def __init__(self , loop , thread_pool , conn):
5151

5252
async def __aenter__(self):
5353
cursor = await self._loop.run_in_executor(self._thread_pool , self._conn.cursor)
54-
return AsyncCursorWarpper(self._loop , self._thread_pool , cursor)
54+
return AsyncCursorWrapper(self._loop , self._thread_pool , cursor)
5555

5656
async def __aexit__(self, exc_type, exc, tb):
5757
return
5858

59-
class AsyncConnectionWarpper:
59+
class AsyncConnectionWrapper:
6060

6161
def __init__(self , loop , thread_pool , conn):
6262
self._loop = loop
6363
self._thread_pool = thread_pool
6464
self._conn = conn
6565

6666
def cursor(self):
67-
return AsyncCursorWarpper_context(self._loop , self._thread_pool , self._conn)
67+
return AsyncCursorWrapper_context(self._loop , self._thread_pool , self._conn)
6868

6969
async def commit(self):
7070
await self._loop.run_in_executor(self._thread_pool , self._conn.commit)
7171

72-
class AsyncConnectionWarpper_context:
72+
class AsyncConnectionWrapper_context:
7373

7474
def __init__(self , loop , thread_pool , pool ):
7575
self._loop = loop
@@ -78,12 +78,12 @@ def __init__(self , loop , thread_pool , pool ):
7878

7979
async def __aenter__(self):
8080
self._conn = await self._loop.run_in_executor(self._thread_pool , self._pool.acquire)
81-
return AsyncConnectionWarpper(self._loop , self._thread_pool , self._conn)
81+
return AsyncConnectionWrapper(self._loop , self._thread_pool , self._conn)
8282

8383
async def __aexit__(self, exc_type, exc, tb):
8484
await self._loop.run_in_executor(self._thread_pool , self._pool.release , self._conn)
8585

86-
class AsyncPoolWarpper:
86+
class AsyncPoolWrapper:
8787

8888
def __init__(self , pool , loop = None):
8989

@@ -103,7 +103,7 @@ def __init__(self , pool , loop = None):
103103
self._pool = pool
104104

105105
def acquire(self):
106-
return AsyncConnectionWarpper_context(self._loop , self._thread_pool , self._pool)
106+
return AsyncConnectionWrapper_context(self._loop , self._thread_pool , self._pool)
107107

108108
async def close(self):
109109
return await self._loop.run_in_executor(self._thread_pool , self._pool.close)
@@ -119,7 +119,7 @@ async def create_pool(host = 'localhost', port = '1521' , user = 'sys', password
119119
if loop == None:
120120
loop = asyncio.get_running_loop()
121121
pool = csor.SessionPool(user , password , f"{host}:{port}/{db}", min = minsize , max = maxsize , increment = 1 , threaded = True , encoding = encoding)
122-
pool = AsyncPoolWarpper(pool)
122+
pool = AsyncPoolWrapper(pool)
123123
await pool.preexciting()
124124
return pool
125125

0 commit comments

Comments
 (0)