diff --git a/backend/src/application/jobs/processar_ranking.py b/backend/src/application/jobs/processar_ranking.py index 913173c..58636ea 100644 --- a/backend/src/application/jobs/processar_ranking.py +++ b/backend/src/application/jobs/processar_ranking.py @@ -36,7 +36,7 @@ class ProcessarRankingJob: resultado = await self.es_client.buscar_todos_consultores( callback=self._processar_batch, - batch_size=5000 + batch_size=10000 ) job_status.mensagem = "Ordenando e gerando posições..." diff --git a/backend/src/domain/value_objects/periodo.py b/backend/src/domain/value_objects/periodo.py index cc54c4b..e2e2bb3 100644 --- a/backend/src/domain/value_objects/periodo.py +++ b/backend/src/domain/value_objects/periodo.py @@ -51,7 +51,7 @@ def mesclar_periodos(periodos: List[Periodo]) -> List[Periodo]: novo_fim = max(ultimo_fim, atual_fim) mesclados[-1] = Periodo( inicio=ultimo.inicio, - fim=novo_fim if not ultimo.ativo else None + fim=None if (ultimo.ativo or p.ativo) else novo_fim ) else: mesclados.append(p)