alex/ASE
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

cambio timeout

Browse Source
This commit is contained in:
alex
2025-06-03 19:37:11 +02:00
parent 991eb6900d
commit ce6b55d2f9
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
load_orchestrator.py
View File

@@ -25,9 +25,9 @@ class WorkerFormatter(logging.Formatter):
logger = logging.getLogger() logger = logging.getLogger()
# Delay tra un processamento CSV e il successivo (in secondi) # 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 # 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): async def get_next_csv_atomic(pool, table_name):
"""Preleva atomicamente il prossimo CSV da elaborare""" """Preleva atomicamente il prossimo CSV da elaborare"""