Skip to content

Commit

Permalink
get and pass traceparent to osbs tasks
Browse files Browse the repository at this point in the history
This is to enable OpenTelemetry tracing in
`osbs`

Signed-off-by: Harsh Modi <[email protected]>
  • Loading branch information
hjmodi committed Sep 12, 2023
1 parent e584447 commit 6f3a5e2
Show file tree
Hide file tree
Showing 2 changed files with 18 additions and 2 deletions.
19 changes: 17 additions & 2 deletions koji_containerbuild/plugins/builder_containerbuild.py
Original file line number Diff line number Diff line change
Expand Up @@ -316,9 +316,10 @@ def osbs(self):
conf_section = DEFAULT_CONF_BINARY_SECTION
elif self.method in BuildSourceContainerTask.Methods:
conf_section = DEFAULT_CONF_SOURCE_SECTION

os_conf = Configuration(conf_section=conf_section)
self._osbs = OSBS(os_conf)
# figure out where to get this from brew otel
traceparent = ''
self._osbs = OSBS(os_conf, traceparent=traceparent)
if not self._osbs:
msg = 'Could not successfully instantiate `osbs`'
raise ContainerError(msg)
Expand Down Expand Up @@ -1011,6 +1012,13 @@ def handler(self, src, target, opts=None):
userdata=opts.get('userdata', None),
)

# need brew instrumentation to be completed to know where we will get this from
traceparent = ''
if traceparent:
kwargs.update({
'traceparent': traceparent,
})

result = self.createContainer(**kwargs)

self.logger.debug("Result: %r", result)
Expand Down Expand Up @@ -1190,6 +1198,13 @@ def handler(self, target, opts=None):
userdata=opts.get('userdata', None),
)

# need brew instrumentation to be completed to know where we will get this from
traceparent = ''
if traceparent:
kwargs.update({
'traceparent': traceparent,
})

result = self.createSourceContainer(**kwargs)

self.logger.debug("Result: %r", result)
Expand Down
1 change: 1 addition & 0 deletions requirements.txt
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
jsonschema
six
koji>=1.26
otel-extensions

0 comments on commit 6f3a5e2

Please sign in to comment.