test: re-enable recoverable skipped tests (+ fix latent LazySpan bug)

[wbarnha]

Description

Re-enables the recoverable @pytest.mark.skip("Needs fixing" / "Fix is TBD") tests across the aiokafka driver, agents, and CLI, and fixes a real bug a skip was hiding. Independent, off master (this consolidates the former #719 + follow-up; #719 is closed in favour of this).

Re-enabled (test-only unless noted)

faust/transport/drivers/aiokafka.py + test_aiokafka.py

• Real bug fix: _transform_span_lazy assigned the unbound LazySpan.finish to span.finish, so span.finish() crashed with missing 1 required positional argument: 'self'. Lazy spans run whenever tracing is enabled — a latent crash the 4 test_transform_span_* tests were masking. Bound it to the span. (source fix)
• Test_VEP_stream_idle_* (2) — updated for the _make_slow_processing_error(msg, causes, setting, current_value) signature (the explanation is now baked into the message; log.error no longer gets those kwargs).
• Test_VEP_no_fetch_since_start::test_timed_out — the fixture stamped a current poll timestamp so the NO_FETCH_SINCE_START branch could never fire; set state_value().timestamp = None (the real "no fetch ever sent" condition).
• test__commit / __CommitFailedError / __IllegalStateError (3) — the mocked assignment() didn't contain TP1, so offsets were filtered to commit({}); point it at TP1. Also dropped the stale supervisor.wakeup() asserts (those calls were removed from _commit in 2020, commit 8d6758f1).

test_agent.py — test_execute_actor__cancelled_running ("Fix is TBD") passes as-is now (skip rot).

test_base.py — test_compat_option was asserting on a Mock; it now grabs the real callback closure from opt.kwargs["callback"] and checks its behaviour against faust/cli/base.py (ensure_object(State), value returned unchanged, stored on State only when the previous value is None and differs from the option default).

Left skipped — genuine source gap (flagged, not forced)

Test_VEP_no_response_since_start::test_timed_out and Test_VEP_no_recent_response::test_timed_out stay skipped with an accurate reason: SLOW_PROCESSING_NO_RESPONSE_SINCE_START / NO_RECENT_RESPONSE are defined in the driver but never emitted — the per-TP broker-response-staleness tracking was dropped, so the driver no longer warns when a broker stops responding to fetches (only when it stops being asked). Out of scope for a test-only change; worth a follow-up.

Verification

test_aiokafka.py + test_agent.py + test_base.py → 295 passed, 3 skipped, 0 failed on CPython; flake8/black/isort clean. Fixes were produced under adversarial faithfulness review (no gutted assertions; mocks stand in only for aiokafka/external).

🤖 Generated with Claude Code

[codecov]

Codecov Report

✅ All modified and coverable lines are covered by tests.
✅ Project coverage is 94.81%. Comparing base (4ab51a5) to head (6692060).

Additional details and impacted files

@@                     Coverage Diff                      @@
##           claude/pypy-agen-cleanup     #723      +/-   ##
============================================================
+ Coverage                     94.18%   94.81%   +0.63%     
============================================================
  Files                           104      104              
  Lines                         11154    11154              
  Branches                       1202     1202              
============================================================
+ Hits                          10505    10576      +71     
+ Misses                          548      482      -66     
+ Partials                        101       96       -5     

☔ View full report in Codecov by Harness.
📢 Have feedback on the report? Share it here.

🚀 New features to boost your workflow:

• ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.