diff --git a/load_orchestrator.py b/load_orchestrator.py index 364f957..4fa0d4b 100755 --- a/load_orchestrator.py +++ b/load_orchestrator.py @@ -25,9 +25,9 @@ class WorkerFormatter(logging.Formatter): logger = logging.getLogger() # Delay tra un processamento CSV e il successivo (in secondi) -CSV_PROCESSING_DELAY = 0.1 +CSV_PROCESSING_DELAY = 0.2 # Tempo di attesa se non ci sono record da elaborare -NO_RECORD_SLEEP = 20 +NO_RECORD_SLEEP = 60 async def get_next_csv_atomic(pool, table_name): """Preleva atomicamente il prossimo CSV da elaborare"""