-1

Tenho o seguinte código

 public string ManterRequisicoesComprasJob(string routingKey, string message)
    {
        try
        {
            var request = message.FromJson<HookOutDto>();
            var keys = request.GetKeys();
            var empresa = keys[0];
            var sistema = keys[1].ToInteger();
            var fornecedor = keys[2].ToInteger();
            var negociacao = keys[3];
            var periodo = keys[4].ToInteger();

            return BatchJob.StartNew(batch =>
            {
                var jobId = batch.Enqueue<IHookTargetService>(x => x.Adicionar(null, request.Id, TargetHook.PROCUREMENT));
                jobId = batch.ContinueJobWith<IRequisicaoCompraService>(jobId, x => x.GetGrupoRequisicoes(null, empresa, fornecedor, sistema, periodo, negociacao));
                jobId = batch.ContinueJobWith<IRequisicaoCompraService>(jobId, x => x.ProcessarRequisicoes(null, empresa, fornecedor, request.Id));
            },
              request.GetJobDescription()
          );
        }
        catch (Exception exception)
        {
            throw exception.Failin();
        }
    }

No job ProcessarRequisicoes estou dando continuidade no código

public async Task<RequisicaoCompraRequest> ProcessarRequisicoes(PerformContext context, string empresa, int fornecedor, long parentId)
    {
        try
        {
            var result = context.GetAntecedentResult<List<ReqFornecSistemaDto>>();
            var jobId = context.BackgroundJob.Id;
            context.SetJobParameter("PROCESSED", jobId);
            var requisicaoJobs = new List<string>();
            BatchJob.Attach(context.GetBatchId(), batch =>
            {
               foreach (var item in result)
                    batch.ContinueJobWith<IRequisicaoCompraService>(jobId, x => x.GetRequisicao(null, empresa, item.Sistema, item.Local, item.Produto)); //duvida

                jobId = batch.ContinueJobWith<IRequisicaoCompraService>(jobId, x => x.GetCachedRequisicoes(null));
                jobId = batch.ContinueJobWith<IRequisicaoCompraService>(jobId, x => x.GetIdFornecedorProcurement(null, empresa, fornecedor));
                jobId = batch.ContinueJobWith<IMapperService>(jobId, x => x.MapFromAntecedentResult(null, typeof(Lar.Procurement.Client.RequisicaoCompra.RequestWrapper), null));
                jobId = batch.ContinueJobWith<IRequisicaoCompraService>(jobId, x => x.Send(null));
                batch.ContinueJobWith<IHookTargetService>(jobId, x => x.AtualizarFinalizado(null, parentId, TargetHook.PROCUREMENT));
            });

            return null;
        }
        catch (Exception exception)
        {
            throw exception.LimTargetException(context, TargetHook.PROCUREMENT);
        }
    }

Quero processar todos os jobs GetRequisicao e após finalizado todos com sucesso, desejo ir para o próximo job que é o GetCachedRequisicoes. Se eu fizer da seguinte forma eu até consigo fazer isso, mas o problema é que a execução é sequencial um job após o outro.

                   foreach (var item in result)
                    jobId = batch.ContinueJobWith<IRequisicaoCompraService>(jobId, x => x.GetRequisicao(null, empresa, item.Sistema, item.Local, item.Produto));

Mas gostaria de executar mais de um job GetRequisicao por vez e somente no final da conclusão de todos, ir para o próximo job GetCachedRequisicoes. Alguém consegue me ajudar?

2 Respostas 2

-2

Segundo a documentação do Hanngfire tem que chamar o método Enqueue. Chamo atenção em especifico para o capitulo Chaining Batches

Continuations allow you to chain multiple batches together. They will be executed once all background jobs of a parent batch finished. Consider the previous example where you have 1000 emails to send. If you want to make final action after sending, just add a continuation:

...

So batches and batch continuations allow you to define workflows and configure what actions will be executed in parallel. This is very useful for heavy computational methods as they can be distributed to different machines.

Traduzindo:

Continuações permitem-lhe encadiar multiplos batches juntos. Eles serão executados assim que os jobs de 2º plano do batch pai esteja concluido. Considere o exemplo anterior onde teve 1000 emails para enviar. Se quiser executar ações após o envio, apenas adicione uma continuação.

Os batchs e as suas continuações permitem-lhe definir workflows e configurar as ações que serão executadas em paralelo. Isto é útil para métodos de computação itensiva já que poderão ser distribuidos por máquinas diferentes.

Já agora, também tem um bug no seu código. Apenas os dados do último item serão tidos em conta, devido à captura do objeto no método anónimo. Para evitar este bug deve fazer a cópia para uma variável local. Por exemplo:

foreach (var item in result)
{
    var localItem = item;
    batch.ContinueJobWith<IRequisicaoCompraService>(jobId, x => x.GetRequisicao(null, empresa, localItem.Sistema, localItem.Local, localItem.Produto));
}
-3

Para executar múltiplos jobs do tipo GetRequisicao em paralelo e aguardar a conclusão de todos antes de seguir para o próximo job GetCachedRequisicoes, você pode usar programação assíncrona e algum mecanismo de controle de concorrência.

Se estiver usando Python use asyncio.

Você deve fazer log-in para responder a esta pergunta.

Esta não é a resposta que você está procurando? Pesquise outras perguntas com a tag .