|
50 | 50 |
|
51 | 51 | event_samples = "tests/event_samples/"
|
52 | 52 |
|
53 |
| -span_to_finish = None |
54 |
| - |
55 |
| - |
56 |
| -def _clean_up_span(): |
57 |
| - global span_to_finish |
58 |
| - if span_to_finish is not None: |
59 |
| - span_to_finish.finish() |
60 |
| - span_to_finish = None |
61 |
| - |
62 |
| - |
63 |
| -def register_span(span): |
64 |
| - global span_to_finish |
65 |
| - _clean_up_span() |
66 |
| - span_to_finish = span |
67 |
| - return span |
68 |
| - |
69 |
| - |
70 |
| -def wrapped_span_creator(span_creator_func): |
71 |
| - def result_func(*args, **kwargs): |
72 |
| - return register_span(span_creator_func(*args, **kwargs)) |
73 |
| - |
74 |
| - return result_func |
75 |
| - |
76 |
| - |
77 |
| -create_inferred_span = wrapped_span_creator(create_inferred_span) |
78 |
| - |
79 | 53 |
|
80 | 54 | class ClientContext(object):
|
81 | 55 | def __init__(self, custom=None):
|
@@ -1709,20 +1683,18 @@ def test_create_inferred_span(mock_span_finish, source, expect):
|
1709 | 1683 | assert actual.get_tag(tag) == value, f"wrong value for tag {tag}"
|
1710 | 1684 |
|
1711 | 1685 | if expect.parent_name is not None:
|
1712 |
| - assert mock_span_finish.call_count == 2 |
| 1686 | + assert mock_span_finish.call_count == 1 |
1713 | 1687 | args, kwargs = mock_span_finish.call_args_list[0]
|
1714 | 1688 | parent = args[0]
|
1715 | 1689 | finish_time = kwargs.get("finish_time") or args[1]
|
1716 | 1690 | assert parent.name == expect.parent_name
|
1717 | 1691 | assert actual.parent_id == parent.span_id
|
1718 | 1692 | assert finish_time == expect.start
|
1719 | 1693 | else:
|
1720 |
| - assert mock_span_finish.call_count < 2 |
| 1694 | + assert mock_span_finish.call_count == 0 |
1721 | 1695 |
|
1722 | 1696 |
|
1723 | 1697 | class TestInferredSpans(unittest.TestCase):
|
1724 |
| - def tearDown(self): |
1725 |
| - _clean_up_span() |
1726 | 1698 |
|
1727 | 1699 | def test_extract_context_from_eventbridge_event(self):
|
1728 | 1700 | event_sample_source = "eventbridge-custom"
|
|
0 commit comments