The fake_record_sql_queries_streaming mock in the span_streaming=True branch exits the inner with record_sql_queries(...) as span: pass block immediately, causing StreamedSpan._end() to fire and serialize the span to the batcher before timestamps are mocked and before add_query_source runs. The assertion assert "code.line.number" not in data will always pass regardless of the threshold logic, meaning a regression that always adds code source would go undetected.

The fake_record_sql_queries_streaming context manager exits the inner with record_sql_queries(...) as span: pass block immediately, which triggers span._end() → client._capture_telemetry() → span._to_json() and batches the already-serialized span before yield span. Since add_query_source(span) is called by the aiomysql wrapper only after the yield, any attributes it might add to span._attributes won't appear in the captured payload — so the assertion assert "code.line.number" not in data always passes regardless of whether the threshold check is broken.