* updates to pass PR checks

Author: reiktar

CHANGELOG.md

@@ -18,7 +18,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Added
 
-- `opentelemtetry-instrumentation-psycopg3` Inital Instrumentation for psycopg3 including asynchronous instrumentation.
+- `opentelemtetry-instrumentation-psycopg3` Initial Instrumentation for psycopg3 including async instrumentation.
   ([#2146](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/2146))
 - `opentelemetry-instrumentation` Added Otel semantic convention opt-in mechanism
   ([#1987](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/1987))

docs-requirements.txt

@@ -36,7 +36,7 @@ kafka-python>=2.0,<3.0
 mysql-connector-python~=8.0
 mysqlclient~=2.1.1
 psutil>=5
-psycopg>=3.117
+psycopg>=3.1.17
 pika>=0.12.0
 pymongo~=3.1
 PyMySQL~=0.9.3

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

@@ -191,7 +191,9 @@ def instrument_connection(connection, tracer_provider=None):
             connection._is_instrumented_by_opentelemetry = False
 
         if not connection._is_instrumented_by_opentelemetry:
-            setattr(connection, _OTEL_CURSOR_FACTORY_KEY, connection.cursor_factory)
+            setattr(
+                connection, _OTEL_CURSOR_FACTORY_KEY, connection.cursor_factory
+            )
             connection.cursor_factory = _new_cursor_factory(
                 tracer_provider=tracer_provider
             )
@@ -205,7 +207,9 @@ def instrument_connection(connection, tracer_provider=None):
     # TODO(owais): check if core dbapi can do this for all dbapi implementations e.g, pymysql and mysql
     @staticmethod
     def uninstrument_connection(connection):
-        connection.cursor_factory = getattr(connection, _OTEL_CURSOR_FACTORY_KEY, None)
+        connection.cursor_factory = getattr(
+            connection, _OTEL_CURSOR_FACTORY_KEY, None
+        )
 
         return connection
 
@@ -241,7 +245,9 @@ async def wrapped_connection(
         new_factory_kwargs = {"db_api": self}
         if base_cursor_factory:
             new_factory_kwargs["base_factory"] = base_cursor_factory
-        kwargs["cursor_factory"] = _new_cursor_async_factory(**new_factory_kwargs)
+        kwargs["cursor_factory"] = _new_cursor_async_factory(
+            **new_factory_kwargs
+        )
         connection = await connect_method(*args, **kwargs)
         self.get_connection_attributes(connection)
         return connection
@@ -305,7 +311,9 @@ def callproc(self, *args, **kwargs):
     return TracedCursorFactory
 
 
-def _new_cursor_async_factory(db_api=None, base_factory=None, tracer_provider=None):
+def _new_cursor_async_factory(
+    db_api=None, base_factory=None, tracer_provider=None
+):
     if not db_api:
         db_api = DatabaseApiAsyncIntegration(
             __name__,

instrumentation/opentelemetry-instrumentation-psycopg3/tests/test_psycopg3_integration.py

@@ -139,7 +139,8 @@ def setUp(self):
             "opentelemetry.instrumentation.psycopg3.pg_cursor", MockCursor
         )
         self.cursor_async_mock = mock.patch(
-            "opentelemetry.instrumentation.psycopg3.pg_async_cursor", MockAsyncCursor
+            "opentelemetry.instrumentation.psycopg3.pg_async_cursor",
+            MockAsyncCursor,
         )
         self.connection_mock = mock.patch("psycopg.connect", MockConnection)
         self.connection_sync_mock = mock.patch(

opentelemetry-instrumentation/src/opentelemetry/instrumentation/bootstrap_gen.py

@@ -125,7 +125,7 @@
         "instrumentation": "opentelemetry-instrumentation-psycopg2==0.44b0.dev",
     },
     {
-        "library": "psycopg >= 3.1.12",
+        "library": "psycopg >= 3.1.17",
         "instrumentation": "opentelemetry-instrumentation-psycopg3==0.44b0.dev",
     },
     {