@@ -53,7 +53,7 @@ def test_gateway_instrumentation(
53
53
f .post (f'/search' , DocumentArray .empty (), continue_on_error = True )
54
54
# give some time for the tracing and metrics exporters to finish exporting.
55
55
# the client is slow to export the data
56
- time .sleep (8 )
56
+ time .sleep (20 )
57
57
58
58
services = get_services (jaeger_port )
59
59
expected_services = ['executor0/rep-0' , 'gateway/rep-0' , client_type ]
@@ -118,7 +118,7 @@ def test_multiprotocol_gateway_instrumentation(
118
118
119
119
# give some time for the tracing and metrics exporters to finish exporting.
120
120
# the client is slow to export the data
121
- time .sleep (8 )
121
+ time .sleep (20 )
122
122
123
123
services = get_services (jaeger_port )
124
124
expected_services = [
@@ -152,7 +152,7 @@ def test_executor_instrumentation(jaeger_port, otlp_collector, otlp_receiver_por
152
152
f .post (f'/search' , DocumentArray .empty (2 ), continue_on_error = True )
153
153
# give some time for the tracing and metrics exporters to finish exporting.
154
154
# the client is slow to export the data
155
- time .sleep (8 )
155
+ time .sleep (20 )
156
156
157
157
client_type = 'GRPCClient'
158
158
client_traces = get_traces (jaeger_port , client_type )
@@ -182,7 +182,7 @@ def test_head_instrumentation(jaeger_port, otlp_collector, otlp_receiver_port):
182
182
f .post (f'/search' , DocumentArray .empty (), continue_on_error = True )
183
183
# give some time for the tracing and metrics exporters to finish exporting.
184
184
# the client is slow to export the data
185
- time .sleep (8 )
185
+ time .sleep (20 )
186
186
187
187
client_type = 'GRPCClient'
188
188
client_traces = get_traces (jaeger_port , client_type )
@@ -235,7 +235,7 @@ def test_flow_metrics(
235
235
f .post (f'/search' , DocumentArray .empty (2 ), continue_on_error = True )
236
236
# give some time for the tracing and metrics exporters to finish exporting.
237
237
# the client is slow to export the data
238
- time .sleep (8 )
238
+ time .sleep (20 )
239
239
240
240
exported_jobs = get_exported_jobs (prometheus_client )
241
241
assert exported_jobs .issubset (instrumented_services_sharded )
0 commit comments