Gerenciador de fluxos de captura e subida de dados no datalake da Prefeitura do Rio de Janeiro | https://docs.dados.rio/guia-desenvolvedores/pipelines/
Ao utilizar a task create_flow_run.map, por padrão, todas as runs são criadas simultaneamente. Isso gera um uso excessivo de recursos no pod. Para tentar otimizar o uso de recursos, será fornecido o argumento scheduled_start_time com uma lista de timestamps para execução sequenciada de todas as runs, sem necessidade de execução simultânea.
Ao utilizar a task
create_flow_run.map
, por padrão, todas as runs são criadas simultaneamente. Isso gera um uso excessivo de recursos no pod. Para tentar otimizar o uso de recursos, será fornecido o argumentoscheduled_start_time
com uma lista de timestamps para execução sequenciada de todas as runs, sem necessidade de execução simultânea.