|
49 | 49 |
|
50 | 50 | event_samples = "tests/event_samples/"
|
51 | 51 |
|
52 |
| -span_to_finish = None |
53 |
| - |
54 |
| - |
55 |
| -def _clean_up_span(): |
56 |
| - global span_to_finish |
57 |
| - if span_to_finish is not None: |
58 |
| - span_to_finish.finish() |
59 |
| - span_to_finish = None |
60 |
| - |
61 |
| - |
62 |
| -def register_span(span): |
63 |
| - global span_to_finish |
64 |
| - _clean_up_span() |
65 |
| - span_to_finish = span |
66 |
| - return span |
67 |
| - |
68 |
| - |
69 |
| -def wrapped_span_creator(span_creator_func): |
70 |
| - def result_func(*args, **kwargs): |
71 |
| - return register_span(span_creator_func(*args, **kwargs)) |
72 |
| - |
73 |
| - return result_func |
74 |
| - |
75 |
| - |
76 |
| -create_inferred_span = wrapped_span_creator(create_inferred_span) |
77 |
| - |
78 | 52 |
|
79 | 53 | class ClientContext(object):
|
80 | 54 | def __init__(self, custom=None):
|
@@ -1881,20 +1855,18 @@ def test_create_inferred_span(mock_span_finish, source, expect):
|
1881 | 1855 | assert actual.get_tag(tag) == value, f"wrong value for tag {tag}"
|
1882 | 1856 |
|
1883 | 1857 | if expect.parent_name is not None:
|
1884 |
| - assert mock_span_finish.call_count == 2 |
| 1858 | + assert mock_span_finish.call_count == 1 |
1885 | 1859 | args, kwargs = mock_span_finish.call_args_list[0]
|
1886 | 1860 | parent = args[0]
|
1887 | 1861 | finish_time = kwargs.get("finish_time") or args[1]
|
1888 | 1862 | assert parent.name == expect.parent_name
|
1889 | 1863 | assert actual.parent_id == parent.span_id
|
1890 | 1864 | assert finish_time == expect.start
|
1891 | 1865 | else:
|
1892 |
| - assert mock_span_finish.call_count < 2 |
| 1866 | + assert mock_span_finish.call_count == 0 |
1893 | 1867 |
|
1894 | 1868 |
|
1895 | 1869 | class TestInferredSpans(unittest.TestCase):
|
1896 |
| - def tearDown(self): |
1897 |
| - _clean_up_span() |
1898 | 1870 |
|
1899 | 1871 | def test_extract_context_from_eventbridge_event(self):
|
1900 | 1872 | event_sample_source = "eventbridge-custom"
|
|
0 commit comments