Fix PEP-8 issues.

Author: khushboovashi

web/pgadmin/tools/sqleditor/__init__.py

@@ -210,8 +210,9 @@ def initialize_viewdata(trans_id, cmd_type, obj_type, sgid, sid, did, obj_id):
 
     filter_sql = _data['filter_sql'] if 'filter_sql' in _data else None
     server_cursor = _data['server_cursor'] if\
-        'server_cursor' in _data and (_data['server_cursor'] == 'true' or
-                                      _data['server_cursor'] is True) else False
+        'server_cursor' in _data and (
+            _data['server_cursor'] == 'true' or _data['server_cursor'] is True
+    ) else False
 
     # Create asynchronous connection using random connection id.
     conn_id = str(secrets.choice(range(1, 9999999)))
@@ -1893,8 +1894,8 @@ def set_pref_options(trans_id, operation):
                                   info='DATAGRID_TRANSACTION_REQUIRED',
                                   status=404)
 
-    if status and conn is not None and \
-        trans_obj is not None and session_obj is not None:
+    if (status and conn is not None and
+            trans_obj is not None and session_obj is not None):
 
         res = None
 

web/pgadmin/tools/sqleditor/command.py

@@ -365,7 +365,8 @@ def __init__(self, **kwargs):
             self.limit = 100
 
         self.thread_native_id = None
-        self.server_cursor = kwargs['server_cursor'] if 'server_cursor' in kwargs else None
+        self.server_cursor = kwargs['server_cursor'] if\
+            'server_cursor' in kwargs else None
 
     def get_primary_keys(self, *args, **kwargs):
         return None, None
@@ -429,6 +430,7 @@ def set_thread_native_id(self, thread_native_id):
     def set_server_cursor(self, server_cursor):
         self.server_cursor = server_cursor
 
+
 class TableCommand(GridCommand):
     """
     class TableCommand(GridCommand)

web/pgadmin/tools/sqleditor/tests/test_server_cursor.py

@@ -96,7 +96,6 @@ def runTest(self):
 
         self.assertEqual(response.status_code, 200)
         csv_data = response.data.decode()
-        print(csv_data)
 
         self.set_server_cursor(False)
 
@@ -105,7 +104,6 @@ def runTest(self):
         response = self.tester.delete(url)
         self.assertEqual(response.status_code, 200)
 
-
         database_utils.disconnect_database(self, self._sid, self._did)
 
     def tearDown(self):

web/pgadmin/tools/sqleditor/utils/start_running_query.py

@@ -149,7 +149,6 @@ def __execute_query(self, conn, session_obj, sql, trans_id, trans_obj):
 
         trans_obj.set_thread_native_id(None)
 
-
         @copy_current_request_context
         def asyn_exec_query(conn, sql, trans_obj, is_rollback_req,
                             app):
@@ -162,8 +161,9 @@ def asyn_exec_query(conn, sql, trans_obj, is_rollback_req,
                     else:
                         _, _ = conn.execute_async(
                             sql, server_cursor=trans_obj.server_cursor)
-                        # # If the transaction aborted for some reason and
-                        # # Auto RollBack is True then issue a rollback to cleanup.
+                        # If the transaction aborted for some reason and
+                        # Auto RollBack is True then issue a rollback
+                        # to cleanup.
                     if is_rollback_req:
                         conn.execute_void("ROLLBACK;")
                 except Exception as e:
@@ -184,11 +184,11 @@ def asyn_exec_query(conn, sql, trans_obj, is_rollback_req,
     @staticmethod
     def is_begin_required_for_sql_query(trans_obj, conn, sql):
 
-        return ((trans_obj.server_cursor
-                 ) or (not trans_obj.auto_commit and
-                conn.transaction_status() == TX_STATUS_IDLE and
-                is_begin_required(sql)
-                ))
+        return ((trans_obj.server_cursor) or (
+            not trans_obj.auto_commit and
+            conn.transaction_status() == TX_STATUS_IDLE and
+            is_begin_required(sql)
+        ))
 
     @staticmethod
     def is_rollback_statement_required(trans_obj, conn):

web/pgadmin/utils/driver/psycopg3/connection.py

@@ -692,7 +692,6 @@ def __reset_auto_commit(self, autocommit):
     async def __reset_auto_commit_for(self, autocommit):
         await self.conn.set_autocommit(autocommit)
 
-
     def __cursor(self, server_cursor=False, scrollable=False):
 
         if not get_crypt_key()[0] and config.SERVER_MODE:
@@ -716,7 +715,7 @@ def __cursor(self, server_cursor=False, scrollable=False):
 
         if self.connected() and cur and not cur.closed:
             if not server_cursor or (
-                server_cursor and type(cur) == AsyncDictServerCursor):
+                    server_cursor and type(cur) is AsyncDictServerCursor):
                 return True, cur
 
         if not self.connected():