@@ -29,10 +29,6 @@ def subscribe
29
29
private
30
30
31
31
def endpoint_run_start ( name , start , finish , id , payload )
32
- puts 'TEST RUN START'
33
- end
34
-
35
- def endpoint_run ( name , start , finish , id , payload )
36
32
# TODO: check span.name and span.type, and set service.name
37
33
env = payload . fetch ( :env )
38
34
# TODO: see if we need to use symbol_key_getter instead
@@ -41,13 +37,16 @@ def endpoint_run(name, start, finish, id, payload)
41
37
env ,
42
38
getter : OpenTelemetry ::Common ::Propagation . rack_env_getter
43
39
)
44
- OpenTelemetry ::Context . with_current ( extracted_context ) do
45
- tracer . in_span ( name , attributes : build_run_attributes ( payload ) , kind : :server ) { }
46
- end
40
+ tracer . start_span ( name , with_parent : extracted_context , attributes : build_run_attributes ( payload ) , kind : :server )
41
+ end
42
+
43
+ def endpoint_run ( name , start , finish , id , payload )
44
+ # This is not working because we are not getting the span started in endpoint_run_start
45
+ span = OpenTelemetry ::Trace . current_span
46
+ span . finish
47
47
end
48
48
49
49
def endpoint_render_start ( name , start , finish , id , payload )
50
- puts 'TEST RENDER START'
51
50
end
52
51
53
52
def endpoint_render ( name , start , finish , id , payload )
0 commit comments