Chunks are skipped when async reads are cancelled during streaming
Mantenedores costumam responder em até 1 dia
Ninguém assumiu esta issue ainda.
Avaliação
- Dificuldade
- 3/5
- Tempo estimado
- 1-2 dias
- Facilidade para iniciantes
- 68/100
Direção de pesquisa
Start by reading ProducerClient.async_stream_submission_chunks() and the regression scenario linked in the issue’s PR discussion. Reproduce cancellation after a chunk is ready but before delivery, then retry the read. Done means the cancelled read leaves that chunk available and subsequent chunks arrive in order.
Escrita pelo modelo de indexação a partir do texto da issue.
Descrição
Description
Cancelling a pending anext() on ProducerClient.async_stream_submission_chunks() can consume a completed chunk before Python receives it. Retrying the read may then skip that chunk.
A regression test in PR discussion 1 demonstrates the scenario: make output chunks ready, start a read, cancel it before delivery, then retry. The next read should still yield the first chunk.
Expected behavior
If a read is cancelled before returning a chunk, the chunk should still be returned by the next read. Subsequent chunks should follow in order.
- Linguagem predominante
- Rust
- Estrelas
- 97
- Forks
- 2
- Merge médio
- 1d 18h
- PRs com merge (30d)
- 4
Preparar o ambiente
- Sem Dockerfile nem arquivo Docker Compose
- Tem um modelo de pull request
- Sem guia de contribuição
Primeiros passos
- Leia a issue inteira e depois o guia de contribuição do projeto.
- Comente na issue dizendo que vai assumir — evita que duas pessoas façam o mesmo trabalho.
- Faça um fork do repositório e trabalhe em uma branch.
- Abra um pull request que referencie o número da issue.
Mais de channable/opsqueue
-
Reserver does not need to be genericTalvez já em andamento @jerbaroo assumiu há 13 dias. Aberta
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 72/100
channable/opsqueue#195 · 1 responsável ·
Mantenedores costumam responder em até 1 dia
-
Make `submissions_canceled` and `add_chunks_done_to_submissions_failed` migrations bidirectionalAberta
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 74/100
Mantenedores costumam responder em até 1 dia
-
Dificuldade 5/5 Mais de uma semana Facilidade para iniciantes 38/100
channable/opsqueue#205 · 1 comentário ·
Mantenedores costumam responder em até 1 dia
-
Dificuldade 4/5 3-5 dias Facilidade para iniciantes 45/100
Mantenedores costumam responder em até 1 dia
-
Dificuldade 4/5 3-5 dias Facilidade para iniciantes 35/100
channable/opsqueue#193 · 2 comentários ·
Mantenedores costumam responder em até 1 dia
Todas as issues de channable/opsqueue
Issues semelhantes
-
good first issue help wanted r-docs
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 72/100
servo/rust-smallvec#824 ·
Mantenedores costumam responder em até 1 dia
-
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 83/100
Mantenedores costumam responder em até 1 dia
-
priority middle
Dificuldade 1/5 Menos de uma hora Facilidade para iniciantes 62/100
KATO-Hiro/AtCoderClans#12940 ·
Mantenedores costumam responder em até 1 dia
-
bug
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 83/100
Mantenedores costumam responder em até 1 dia
-
o8 next debug build aborts on Glass to Dark appearance switch (nil identifier messaged before check)Abertabug
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 78/100
hurttlocker/o8#5112 ·