Function worker

tests/smoke_test_mcp.py:196–203

()

    import threading
    errors = []
    def worker():
        try:
            for _ in range(20):
                s = store.create("a", "b", {}, [])
                store.get(s.session_id)
                store.remove(s.session_id)
        except Exception as e:
            errors.append(str(e))
    threads = [threading.Thread(target=worker) for _ in range(5)]
    for t in threads:
        t.start()