fix ruff and linting issues

Author: beijiez

instrumentation/opentelemetry-instrumentation-aiopg/src/opentelemetry/instrumentation/aiopg/__init__.py

@@ -35,19 +35,19 @@
     cnx.close()
 
     pool = await aiopg.create_pool(database='Database')
-    
+
     cnx = await pool.acquire()
     cursor = await cnx.cursor()
     await cursor.execute("INSERT INTO test (testField) VALUES (123)")
     cursor.close()
     cnx.close()
-    
+
     cnx = AiopgInstrumentor().instrument_connection(cnx)
     cursor = await cnx.cursor()
     await cursor.execute("INSERT INTO test (testField) VALUES (123)")
     cursor.close()
     cnx.close()
-    
+
 API
 ---
 """

instrumentation/opentelemetry-instrumentation-mysql/src/opentelemetry/instrumentation/mysql/__init__.py

@@ -33,7 +33,7 @@
     cursor.execute("INSERT INTO test (testField) VALUES (123)")
     cursor.close()
     cnx.close()
-    
+
     cnx = MySQLInstrumentor().instrument_connection(cnx)
     cursor = cnx.cursor()
     cursor.execute("INSERT INTO test (testField) VALUES (123)")

instrumentation/opentelemetry-instrumentation-mysqlclient/src/opentelemetry/instrumentation/mysqlclient/__init__.py

@@ -55,7 +55,7 @@
     cnx.commit()
     cursor.close()
     cnx.close()
-    
+
     instrumented_cnx = MySQLClientInstrumentor.instrument_connection(
         cnx,
         enable_commenter=True,
@@ -197,7 +197,7 @@ def instrument_connection(
                     - `driver_paramstyle`: Adds the parameter style.
                     - `opentelemetry_values`: Includes traceparent values.
                 Refer to *SQLCommenter Configurations* above for more information
-                
+
         Returns:
             An instrumented MySQL connection with OpenTelemetry support enabled.
         """

instrumentation/opentelemetry-instrumentation-psycopg/src/opentelemetry/instrumentation/psycopg/__init__.py

@@ -92,18 +92,18 @@
     PsycopgInstrumentor().instrument()
 
     cnx = psycopg.connect(database='Database')
-    
+
     cursor = cnx.cursor()
     cursor.execute("INSERT INTO test (testField) VALUES (123)")
     cursor.close()
     cnx.close()
-    
+
     instrumented_cnx = instrument_connection(cnx)
     cursor = instrumented_cnx.cursor()
     cursor.execute("INSERT INTO test (testField) VALUES (123)")
     cursor.close()
     instrumented_cnx.close()
-    
+
 API
 ---
 """
@@ -205,15 +205,15 @@ def _uninstrument(self, **kwargs):
     def instrument_connection(connection, tracer_provider=None):
         """Enable instrumentation in a psycopg connection.
 
-            Args:
-                connection: psycopg.Connection
-                    The psycopg connection object to be instrumented.
-                tracer_provider: opentelemetry.trace.TracerProvider, optional
-                    The TracerProvider to use for instrumentation. If not provided,
-                    the global TracerProvider will be used.
+        Args:
+            connection: psycopg.Connection
+                The psycopg connection object to be instrumented.
+            tracer_provider: opentelemetry.trace.TracerProvider, optional
+                The TracerProvider to use for instrumentation. If not provided,
+                the global TracerProvider will be used.
 
-            Returns:
-                An instrumented psycopg connection object.
+        Returns:
+            An instrumented psycopg connection object.
         """
         if not hasattr(connection, "_is_instrumented_by_opentelemetry"):
             connection._is_instrumented_by_opentelemetry = False

instrumentation/opentelemetry-instrumentation-psycopg2/src/opentelemetry/instrumentation/psycopg2/__init__.py

@@ -92,7 +92,7 @@
     Psycopg2Instrumentor().instrument()
 
     cnx = psycopg2.connect(database='Database')
-    
+
     cursor = cnx.cursor()
     cursor.execute("INSERT INTO test (testField) VALUES (123)")
     cursor.close()
@@ -168,17 +168,17 @@ def _uninstrument(self, **kwargs):
     def instrument_connection(connection, tracer_provider=None):
         """Enable instrumentation in a psycopg2 connection.
 
-            Args:
-                connection: psycopg2.extensions.connection
-                    The psycopg2 connection object to be instrumented.
-                tracer_provider: opentelemetry.trace.TracerProvider, optional
-                    The TracerProvider to use for instrumentation. If not specified,
-                    the global TracerProvider will be used.
+        Args:
+            connection: psycopg2.extensions.connection
+                The psycopg2 connection object to be instrumented.
+            tracer_provider: opentelemetry.trace.TracerProvider, optional
+                The TracerProvider to use for instrumentation. If not specified,
+                the global TracerProvider will be used.
 
-            Returns:
-                An instrumented psycopg2 connection object.
+        Returns:
+            An instrumented psycopg2 connection object.
         """
-        
+
         if not hasattr(connection, "_is_instrumented_by_opentelemetry"):
             connection._is_instrumented_by_opentelemetry = False
 

instrumentation/opentelemetry-instrumentation-pymysql/src/opentelemetry/instrumentation/pymysql/__init__.py

@@ -56,12 +56,12 @@
     cnx.commit()
     cursor.close()
     cnx.close()
-    
+
     instrumented_cnx = PyMySQLInstrumentor().instrument_connection(
         cnx,
         enable_commenter=True,
         commenter_options={
-            "db_driver": True, 
+            "db_driver": True,
             "mysql_client_version": True
         }
     )

instrumentation/opentelemetry-instrumentation-sqlite3/src/opentelemetry/instrumentation/sqlite3/__init__.py

@@ -31,23 +31,19 @@
     SQLite3Instrumentor().instrument()
 
     cnx = sqlite3.connect(':memory:')
-    
     cursor = cnx.cursor()
     cursor.execute("CREATE TABLE test (testField INTEGER)")
     cursor.execute("INSERT INTO test (testField) VALUES (123)")
     cursor.close()
     cnx.close()
-    
     conn = sqlite3.connect(":memory:")
-    
     instrumented_connection = SQLite3Instrumentor.instrument_connection(conn)
     cursor = instrumented_connection.cursor()
     cursor.execute("CREATE TABLE test (testField INTEGER)")
     cursor.execute("INSERT INTO test (testField) VALUES (123)")
-    cursor.execute("SELECT * FROM test")     
+    cursor.execute("SELECT * FROM test")
     cursor.close()
     instrumented_connection.close()
-
 API
 ---
 """
@@ -119,11 +115,10 @@ def instrument_connection(
             telemetry for tracing database operations.
 
         Notes:
-            - Instrumentation must be explicitly applied to the connection object 
-              for tracing to work. This is not done automatically by simply calling 
+            - Instrumentation must be explicitly applied to the connection object
+              for tracing to work. This is not done automatically by simply calling
               `SQLite3Instrumentor().instrument()`.
         """
-
         return dbapi.instrument_connection(
             __name__,
             connection,
@@ -146,4 +141,3 @@ def uninstrument_connection(
             An uninstrumented connection.
         """
         return dbapi.uninstrument_connection(connection)
-

instrumentation/opentelemetry-instrumentation-sqlite3/tests/test_sqlite3.py

@@ -29,7 +29,9 @@ def setUp(self):
         self._cursor = self._connection.cursor()
         self._connection2 = dbapi2.connect(":memory:")
         self._cursor2 = self._connection2.cursor()
-        self._connection3 = SQLite3Instrumentor.instrument_connection(dbapi2.connect(":memory:"))
+        self._connection3 = SQLite3Instrumentor.instrument_connection(
+            dbapi2.connect(":memory:")
+        )
         self._cursor3 = self._connection3.cursor()
 
     def tearDown(self):
@@ -84,7 +86,7 @@ def test_execute(self):
         with self._tracer.start_as_current_span("rootSpan"):
             self._cursor2.execute(stmt)
         self.validate_spans("CREATE")
-        
+
         with self._tracer.start_as_current_span("rootSpan"):
             self._cursor3.execute(stmt)
         self.validate_spans("CREATE")
@@ -107,12 +109,11 @@ def test_executemany(self):
         with self._tracer.start_as_current_span("rootSpan"):
             self._cursor3.executemany(stmt, data)
         self.validate_spans("INSERT")
-        
+
     def test_callproc(self):
         """Should create a child span for callproc"""
         with self._tracer.start_as_current_span("rootSpan"), self.assertRaises(
             Exception
         ):
             self._cursor.callproc("test", ())
             self.validate_spans("test")
-