Replaced argument 'async' with 'async_' chtd#103

donalm · Sep 22, 2018 · 59d6ada · 59d6ada
1 parent e29932c
commit 59d6ada
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/psycopg2cffi/__init__.py b/psycopg2cffi/__init__.py
@@ -88,11 +88,11 @@ def connect(dsn=None,
     if port is not None:
         items.append(('port', port))
 
-    kwasync = {}
+    async_ = False
     if 'async' in kwargs:
-        kwasync['async'] = kwargs.pop('async')
+        async_ = kwargs.pop('async')
     if 'async_' in kwargs:
-        kwasync['async_'] = kwargs.pop('async_')
+        async_ = kwargs.pop('async_')
 
     items.extend([(k, v) for (k, v) in kwargs.items() if v is not None])
 
@@ -108,7 +108,7 @@ def connect(dsn=None,
             dsn = " ".join(["%s=%s" % (k, _param_escape(str(v)))
                 for (k, v) in items])
 
-    conn = _connect(dsn, connection_factory=connection_factory, **kwasync)
+    conn = _connect(dsn, connection_factory=connection_factory, async_=async_)
     if cursor_factory is not None:
         conn.cursor_factory = cursor_factory