trace parts of osbs-client calls

expecially tasks with http requests

Signed-off-by: Harsh Modi <[email protected]>

osbs/cli/main.py

@@ -14,6 +14,10 @@
 
 import sys
 import argparse
+
+from opentelemetry.sdk.environment_variables import OTEL_SERVICE_NAME
+from otel_extensions import get_tracer
+
 from osbs import set_logging
 from osbs.api import OSBS
 from osbs.conf import Configuration
@@ -22,6 +26,7 @@
 from osbs.exceptions import (OsbsNetworkException, OsbsException, OsbsAuthException,
                              OsbsResponseException)
 from osbs.utils import UserWarningsStore
+from osbs.utils.otel import init_otel
 
 logger = logging.getLogger('osbs')
 
@@ -415,6 +420,8 @@ def main():
         logger.error("Configuration error: %s", ex.message)
         return -1
 
+    init_otel(otel_url=os_conf.get_otel_url(),
+              traceparent=args.traceparent)
     is_verbose = os_conf.get_verbosity()
 
     if args.quiet:
@@ -427,7 +434,13 @@ def main():
 
     return_value = -1
     try:
-        return_value = args.func(args)
+        span_name = "binary_build_pipeline"
+        if getattr(args, 'func', None) is cmd_build_source_container:
+            span_name = "source_build_pipeline"
+        tracer = get_tracer(module_name=span_name, service_name=OTEL_SERVICE_NAME)
+
+        with tracer.start_as_current_span(span_name):
+            return_value = args.func(args)
     except AttributeError:
         if hasattr(args, 'func'):
             raise

osbs/constants.py

@@ -74,6 +74,8 @@
 # number of seconds to wait, before retrying on openshift not found
 OS_NOT_FOUND_MAX_WAIT = 1
 
+OTEL_SERVICE_NAME = "osbs"
+
 ISOLATED_RELEASE_FORMAT = re.compile(r'^\d+\.\d+(\..+)?$')
 RELEASE_LABEL_FORMAT = re.compile(r"""^\d+             # First character must be a digit
                                       ([._]?           # allow separators between groups

osbs/tekton.py

@@ -14,6 +14,7 @@
 from typing import Dict, List, Tuple, Callable, Any
 from datetime import datetime
 
+from otel_extensions import instrumented
 
 from osbs.exceptions import OsbsResponseException, OsbsAuthException, OsbsException
 from osbs.constants import (DEFAULT_NAMESPACE, SERVICEACCOUNT_SECRET, SERVICEACCOUNT_TOKEN,
@@ -422,6 +423,7 @@ def pipeline_run_url(self):
             )
         return self._pipeline_run_url
 
+    @instrumented
     def start_pipeline_run(self):
         if not self.input_data:
             raise OsbsException("No input data provided for pipeline run to start")
@@ -445,6 +447,7 @@ def start_pipeline_run(self):
         )
         return response.json()
 
+    @instrumented
     def remove_pipeline_run(self):
         url = self.os.build_url(
             self.api_path,
@@ -458,6 +461,7 @@ def remove_pipeline_run(self):
         return response.json()
 
     @retry_on_conflict
+    @instrumented
     def cancel_pipeline_run(self):
         data = copy.deepcopy(self.minimal_data)
         data['spec']['status'] = 'CancelledRunFinally'
@@ -479,6 +483,7 @@ def cancel_pipeline_run(self):
             raise OsbsException(exc_msg)
         return response_json
 
+    @instrumented
     def get_info(self, wait=False):
         if wait:
             self.wait_for_start()
@@ -731,6 +736,7 @@ def load_result(result: Dict[str, str]) -> Tuple[str, Any]:
             name: value for name, value in map(load_result, pipeline_results) if value is not None
         }
 
+    @instrumented
     def wait_for_start(self):
         """
         https://tekton.dev/docs/pipelines/pipelineruns/#monitoring-execution-status