improve(apm): enhance Elastic APM client initialization to prevent duplicates

- Use elasticapm.get_client() before creating new clients in tracing decorators
- Apply same pattern to gRPC server interceptors (sync and async)
- Prevent potential memory leaks and improve performance by reusing existing clients
- Maintain backward compatibility while optimizing resource usage

Author: HosseinNejatiJavaremi

archipy/helpers/decorators/tracing.py

@@ -78,13 +78,14 @@ def wrapper(*args: Any, **kwargs: Any) -> Any:
                     logging.exception("Failed to initialize Sentry or start transaction")
 
             # Initialize and track with Elastic APM if enabled
-            elastic_client = None
             if config.ELASTIC_APM.IS_ENABLED:
                 try:
                     import elasticapm
 
                     # Initialize Elastic APM client with config
-                    elastic_client = elasticapm.Client(config.ELASTIC_APM.model_dump())
+                    elastic_client = elasticapm.get_client()
+                    if not elastic_client:
+                        elastic_client = elasticapm.Client(config.ELASTIC_APM.model_dump())
                     elastic_client.begin_transaction(transaction_type="function")
                 except ImportError:
                     logging.debug("elasticapm is not installed, skipping Elastic APM transaction capture.")

archipy/helpers/interceptors/grpc/trace/server_interceptor.py

@@ -85,12 +85,12 @@ def intercept(
                     logging.exception("Failed to create Sentry transaction for gRPC server call")
 
             # Handle Elastic APM if enabled
-            elastic_client = None
             if config.ELASTIC_APM.IS_ENABLED:
                 try:
                     # Get the Elastic APM client
-                    elastic_client = elasticapm.Client(config.ELASTIC_APM.model_dump())
-
+                    elastic_client = elasticapm.get_client()
+                    if not elastic_client:
+                        elastic_client = elasticapm.Client(config.ELASTIC_APM.model_dump())
                     # Check if a trace parent header is present in the metadata
                     if parent := elasticapm.trace_parent_from_headers(metadata_dict):
                         # Start a transaction linked to the distributed trace
@@ -203,11 +203,12 @@ async def intercept(
                     logging.exception("Failed to create Sentry transaction for async gRPC server call")
 
             # Handle Elastic APM if enabled
-            elastic_client = None
             if config.ELASTIC_APM.IS_ENABLED:
                 try:
                     # Get the Elastic APM client
-                    elastic_client = elasticapm.Client(config.ELASTIC_APM.model_dump())
+                    elastic_client = elasticapm.get_client()
+                    if not elastic_client:
+                        elastic_client = elasticapm.Client(config.ELASTIC_APM.model_dump())
 
                     # Check if a trace parent header is present in the metadata
                     if parent := elasticapm.trace_parent_from_headers(metadata_dict):

docs/changelog.md

@@ -2,6 +2,18 @@
 
 All notable changes to ArchiPy are documented in this changelog, organized by version.
 
+## [3.13.9] - 2025-10-15
+
+### Improved
+
+#### Elastic APM Client Initialization
+
+- **Enhanced Client Reuse** - Improved Elastic APM client initialization to prevent duplicate client creation
+    - Updated tracing decorators to use `elasticapm.get_client()` before creating new clients
+    - Applied same pattern to gRPC server interceptors (both sync and async)
+    - Prevents potential memory leaks and improves performance by reusing existing clients
+    - Maintains backward compatibility while optimizing resource usage
+
 ## [3.13.8] - 2025-10-15
 
 ### Changed