Commits
Click on a commit to change the comparison rangeFix type hint and Python 3.9/3.10 compatibility
- Add missing type hint for flow parameter (orm_models.Flow)
- Replace asyncio.Barrier with custom SimpleBarrier implementation
for Python 3.9/3.10 compatibility
- Import orm_models for proper type annotation Update test_task_run_recorder_handles_concurrent_inserts to use SimpleBarrier
Replace the two asyncio.Event objects with SimpleBarrier for
cleaner and more consistent synchronization. This simplifies
the test and makes it use the same pattern as other concurrent
tests. Update duplicate event test for advisory lock behavior
The test now verifies that duplicate events are handled gracefully
without causing server overload. With advisory locks:
- Concurrent duplicates are skipped rather than causing errors
- Sequential duplicates may go to dead letter queue
- No infinite retry loops occur (fixes #15607)
🤖 Generated with [Claude Code](https://claude.ai/code)
Co-Authored-By: Claude <noreply@anthropic.com>