def METHOD_NAME(concurrency_instance):
    run_id = make_new_run_id()
    assert concurrency_instance.event_log_storage.get_concurrency_info("foo").slot_count == 0
    with InstanceConcurrencyContext(concurrency_instance, run_id) as context:
        assert context.claim("foo", "a")
        assert context.claim("foo", "b")
        assert context.claim("foo", "d")
        assert context.claim("foo", "e")
        assert not context.has_pending_claims()
        foo_info = concurrency_instance.event_log_storage.get_concurrency_info("foo")
        assert foo_info.slot_count == 0
        assert foo_info.active_slot_count == 0