.

Author: alexander-alderman-webb

tests/conftest.py

@@ -466,8 +466,8 @@ def append(envelope):
 
         def flush(timeout=None, callback=None):
             real_flush(timeout=timeout, callback=callback)
-            items_w.write(json.dumps(telemetry).encode("utf-8"))
-            items_w.write(b"\n")
+            items_w.write(json.dumps(telemetry).encode("utf-8") + b"\n")
+            items_w.write(b"flush\n")
 
         monkeypatch.setattr(test_client.transport, "capture_envelope", append)
         monkeypatch.setattr(test_client, "flush", flush)

tests/integrations/rq/test_rq.py

@@ -6,6 +6,7 @@
 
 import sentry_sdk
 from sentry_sdk import start_transaction
+from sentry_sdk.consts import SPANDATA
 from sentry_sdk.integrations.rq import RqIntegration
 from sentry_sdk.utils import SENSITIVE_DATA_SUBSTITUTE, parse_version
 
@@ -197,6 +198,10 @@ def test_transaction_with_error(
             spans[44]["attributes"]["sentry.origin"]
             == error_event["contexts"]["trace"]["origin"]
         )
+        assert (
+            spans[44]["attributes"][SPANDATA.CODE_FUNCTION_NAME]
+            == "tests.integrations.rq.test_rq.chew_up_shoes"
+        )
     else:
         events = capture_events()
 
@@ -360,7 +365,6 @@ def test_tracing_disabled(
         events = capture_events()
 
         scope = sentry_sdk.get_isolation_scope()
-
         queue.enqueue(crashing_job, foo=None)
         worker.work(burst=True)