Skip to content

Commit

Permalink
fix some tests
Browse files Browse the repository at this point in the history
  • Loading branch information
Zylphrex committed Mar 18, 2024
1 parent f44dec5 commit 2344d79
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 56 deletions.
20 changes: 10 additions & 10 deletions tests/integrations/boto3/test_s3.py
Original file line number Diff line number Diff line change
Expand Up @@ -65,12 +65,10 @@ def test_streaming(sentry_init, capture_events):
span1 = event["spans"][0]
assert span1["op"] == "http.client"
assert span1["description"] == "aws.s3.GetObject"
assert span1["data"] == {
"http.method": "GET",
"aws.request.url": "https://bucket.s3.amazonaws.com/foo.pdf",
"http.fragment": "",
"http.query": "",
}
assert span1["data"]["http.method"] == "GET"
assert span1["data"]["aws.request.url"] == "https://bucket.s3.amazonaws.com/foo.pdf"
assert span1["data"]["http.fragment"] == ""
assert span1["data"]["http.query"] == ""

span2 = event["spans"][1]
assert span2["op"] == "http.client.stream"
Expand Down Expand Up @@ -123,7 +121,9 @@ def test_omit_url_data_if_parsing_fails(sentry_init, capture_events):
transaction.finish()

(event,) = events
assert event["spans"][0]["data"] == {
"http.method": "GET",
# no url data
}
assert event["spans"][0]["data"]["http.method"] == "GET"

# url data not present due to failed parsing
assert "aws.request.url" not in event["spans"][0]["data"]
assert "http.fragment" not in event["spans"][0]["data"]
assert "http.query" not in event["spans"][0]["data"]
46 changes: 0 additions & 46 deletions tests/test_profiler.py
Original file line number Diff line number Diff line change
Expand Up @@ -555,52 +555,6 @@ def test_extract_stack_with_cache(frame, depth):
assert frame1 is frame2, i


@requires_python_version(3, 3)
@requires_gevent
def test_get_current_thread_id_gevent_in_thread():
results = Queue(maxsize=1)

def target():
job = gevent.spawn(get_current_thread_id)
job.join()
results.put(job.value)

thread = threading.Thread(target=target)
thread.start()
thread.join()
assert thread.ident == results.get(timeout=1)


@requires_python_version(3, 3)
def test_get_current_thread_id_running_thread():
results = Queue(maxsize=1)

def target():
results.put(get_current_thread_id())

thread = threading.Thread(target=target)
thread.start()
thread.join()
assert thread.ident == results.get(timeout=1)


@requires_python_version(3, 3)
def test_get_current_thread_id_main_thread():
results = Queue(maxsize=1)

def target():
# mock that somehow the current thread doesn't exist
with mock.patch("threading.current_thread", side_effect=[None]):
results.put(get_current_thread_id())

thread_id = threading.main_thread().ident if sys.version_info >= (3, 4) else None

thread = threading.Thread(target=target)
thread.start()
thread.join()
assert thread_id == results.get(timeout=1)


def get_scheduler_threads(scheduler):
return [thread for thread in threading.enumerate() if thread.name == scheduler.name]

Expand Down

0 comments on commit 2344d79

Please sign in to comment.