File tree Expand file tree Collapse file tree 2 files changed +26
-0
lines changed
exporter/opentelemetry-exporter-otlp-proto-grpc/tests Expand file tree Collapse file tree 2 files changed +26
-0
lines changed Original file line number Diff line number Diff line change @@ -874,6 +874,19 @@ def test_shutdown_wait_last_export(self):
874
874
finally :
875
875
export_thread .join ()
876
876
877
+ def test_export_over_closed_grpc_channel (self ):
878
+ add_MetricsServiceServicer_to_server (
879
+ MetricsServiceServicerSUCCESS (), self .server
880
+ )
881
+ self .exporter .export (self .metrics ["sum_int" ])
882
+ self .exporter .shutdown ()
883
+ data = self .exporter ._translate_data (self .metrics ["sum_int" ])
884
+ with self .assertRaises (ValueError ) as err :
885
+ self .exporter ._client .Export (request = data )
886
+ self .assertEqual (
887
+ str (err .exception ),
888
+ "Cannot invoke RPC on closed channel!"
889
+ )
877
890
def test_aggregation_temporality (self ):
878
891
# pylint: disable=protected-access
879
892
Original file line number Diff line number Diff line change @@ -1017,6 +1017,19 @@ def test_shutdown_wait_last_export(self):
1017
1017
finally :
1018
1018
export_thread .join ()
1019
1019
1020
+ def test_export_over_closed_grpc_channel (self ):
1021
+ add_TraceServiceServicer_to_server (
1022
+ TraceServiceServicerSUCCESS (), self .server
1023
+ )
1024
+ self .exporter .export ([self .span ])
1025
+ self .exporter .shutdown ()
1026
+ data = self .exporter ._translate_data ([self .span ])
1027
+ with self .assertRaises (ValueError ) as err :
1028
+ self .exporter ._client .Export (request = data )
1029
+ self .assertEqual (
1030
+ str (err .exception ),
1031
+ "Cannot invoke RPC on closed channel!"
1032
+ )
1020
1033
1021
1034
def _create_span_with_status (status : SDKStatus ):
1022
1035
span = _Span (
You can’t perform that action at this time.
0 commit comments