feedback: pass in tracer_provider directly rather than kwargs

Author: jfmyers9

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

@@ -88,19 +88,20 @@ def _instrument(self, **kwargs):
         Returns:
             An instrumented engine if passed in as an argument, None otherwise.
         """
-        _w("sqlalchemy", "create_engine", _wrap_create_engine(kwargs))
-        _w("sqlalchemy.engine", "create_engine", _wrap_create_engine(kwargs))
+        tracer_provider = kwargs.get("tracer_provider")
+        _w("sqlalchemy", "create_engine", _wrap_create_engine(tracer_provider))
+        _w("sqlalchemy.engine", "create_engine", _wrap_create_engine(tracer_provider))
         if parse_version(sqlalchemy.__version__).release >= (1, 4):
             _w(
                 "sqlalchemy.ext.asyncio",
                 "create_async_engine",
-                _wrap_create_async_engine(kwargs),
+                _wrap_create_async_engine(tracer_provider),
             )
 
         if kwargs.get("engine") is not None:
             return EngineTracer(
                 _get_tracer(
-                    kwargs.get("engine"), kwargs.get("tracer_provider")
+                    kwargs.get("engine"), tracer_provider
                 ),
                 kwargs.get("engine"),
             )

instrumentation/opentelemetry-instrumentation-sqlalchemy/src/opentelemetry/instrumentation/sqlalchemy/engine.py

@@ -43,9 +43,7 @@ def _get_tracer(engine, tracer_provider=None):
 
 
 # pylint: disable=unused-argument
-def _wrap_create_async_engine(kwargs):
-    tracer_provider = kwargs.get("tracer_provider")
-
+def _wrap_create_async_engine(tracer_provider=None):
     def _wrap_create_async_engine_internal(func, module, args, kwargs):
         """Trace the SQLAlchemy engine, creating an `EngineTracer`
         object that will listen to SQLAlchemy events.
@@ -58,9 +56,7 @@ def _wrap_create_async_engine_internal(func, module, args, kwargs):
 
 
 # pylint: disable=unused-argument
-def _wrap_create_engine(kwargs):
-    tracer_provider = kwargs.get("tracer_provider")
-
+def _wrap_create_engine(tracer_provider=None):
     def _wrap_create_engine_internal(func, module, args, kwargs):
         """Trace the SQLAlchemy engine, creating an `EngineTracer`
         object that will listen to SQLAlchemy events.