Bogdanp/dramatiq

Feature Request: iterate over a group as actors complete

Aberta

#278 aberto em 27 de fev. de 2020

Ver no GitHubGuia do colaborador
 (3 comentários) (0 reação) (0 responsável)Python (277 forks)batch import
enhancementhelp wanted

Métricas do repositório

Stars
 (3.884 estrelas)
Métricas de merge de PR
 (Mesclagem média 20d 20h) (10 fundiu PRs em 30d)

Description

concurrent.futures (and probably other Python stdlib stuff) has the idea of iterating over results from concurrent processing as they are completed:

https://docs.python.org/3/library/concurrent.futures.html#concurrent.futures.as_completed

I'm currently using the Group.get_results() method to iterate over a group of results, but it would be nice to be able to do that as the results come back instead of in the order they were queued. That way, if I have a network request hang at the very beginning, I can get other work done while that action times out and is retried.

Guia do colaborador

Direção de pesquisa
Estude a implementação de Group.get results() do Dramatiq e a função concurrent.futures.as completed. Projete um método as completed para Group que produza resultados à medida que se tornam disponíveis, provavelmente consultando backends de resultado (ex.: Redis) para cada ID de mensagem.
Pilha de tecnologia
python
Domain
backend
Tipo Issue
Funcionalidade
DifficultyDificuldade de implementação estimada para um novo contribuidor, de 1 para alterações muito pequenas a 5 para trabalho de nível especializado.
2
Tempo estimadoUm intervalo de tempo aproximado para um colaborador experiente investigar, implementar, testar e preparar um pull request.
Meio dia
Status da atividadeQuão disponível o issue aparece agora: novo, ativo, obsoleto, bloqueado ou aguardando entrada do mantenedor.
Ativo
ClarityCom que clareza o issue explica a mudança esperada, os critérios de aceitação e a próxima etapa.
Claro
Prerequisites
PythonDramatiq
Simpatia para novatosUma pontuação de 1 a 100 que estima o quão acessível este issue é para colaboradores iniciantes.
60