Skip to content

Commit

Permalink
Update agent.instrumentation.python.deep.py
Browse files Browse the repository at this point in the history
  • Loading branch information
plengauer authored Jan 7, 2025
1 parent e4900fb commit 189694d
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
carrier = { "traceparent": traceparent }
new_context = propagator.extract(carrier=carrier)
attach(new_context)

def inject_env(env):
if not env:
env = os.environ.copy()
Expand All @@ -38,16 +38,16 @@ def inject_file(file):
def inject_arguments(file, args):
if type(args) is tuple:
args = list(args)
return [ args[0], '-c', '. otel.sh\n_otel_inject "' + file + '" "$@"', 'python' ] + args[1:]
return [ args[0], '-c', '. otel.sh\n_otel_inject "' + str(file) + '" "$@"', 'python' ] + args[1:]

def observed_os_execv(original_os_execve, file, args):
print('os.execv(' + str(file) + ', ' + str(args) + ')', file=sys.stderr)
print('os.execv(' + inject_file(file) + ', [' + ','.join(inject_arguments(file, args)) + '], ' + str(inject_env(None)) + ')', file=sys.stderr)
return original_os_execve(inject_file(file), inject_arguments(file, args), inject_env(None))

def observed_os_execve(original_os_execve, file, args, env):
print('os.execv(' + str(file) + ', ' + str(args) + ', ' + str(env) + ')', file=sys.stderr)
print('os.execv(' + inject_file(file) + ', [' + ','.join(inject_arguments(file, args)) + '], ' + str(inject_env(env)) + ')', file=sys.stderr)
print('os.execve(' + str(file) + ', ' + str(args) + ', ' + str(env) + ')', file=sys.stderr)
print('os.execve(' + inject_file(file) + ', [' + ','.join(inject_arguments(file, args)) + '], ' + str(inject_env(env)) + ')', file=sys.stderr)
return original_os_execve(inject_file(file), inject_arguments(file, args), inject_env(env))

# def observed_os_execvp(original_os_execvpe, file, args):
Expand Down

0 comments on commit 189694d

Please sign in to comment.