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

fix pylint

Browse Source
This commit is contained in:
alex
2025-09-03 21:05:19 +02:00
parent 9b3f1171f3
commit 39dba8f54a
1 changed files with 14 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/send_orchestrator.py
View File

@@ -1,4 +1,7 @@
#!.venv/bin/python #!.venv/bin/python
"""
Orchestratore dei worker che inviano i dati ai clienti
"""
# Import necessary libraries # Import necessary libraries
import logging import logging
@@ -11,8 +14,9 @@ from utils.csv.loaders import get_next_csv_atomic
from utils.orchestrator_utils import run_orchestrator, worker_context from utils.orchestrator_utils import run_orchestrator, worker_context
from utils.connect.send_data import process_workflow_record from utils.connect.send_data import process_workflow_record
from utils.general import alterna_valori from utils.general import alterna_valori
#from utils.ftp.send_data import ftp_send_elab_csv_to_customer, api_send_elab_csv_to_customer, ftp_send_raw_csv_to_customer, api_send_raw_csv_to_customer
# from utils.ftp.send_data import ftp_send_elab_csv_to_customer, api_send_elab_csv_to_customer, \
# ftp_send_raw_csv_to_customer, api_send_raw_csv_to_customer
# Initialize the logger for this module # Initialize the logger for this module
@@ -23,6 +27,7 @@ ELAB_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 = 30 NO_RECORD_SLEEP = 30
async def worker(worker_id: int, cfg: object, pool: object) -> None: async def worker(worker_id: int, cfg: object, pool: object) -> None:
"""Esegue il ciclo di lavoro per l'invio dei dati. """Esegue il ciclo di lavoro per l'invio dei dati.
@@ -42,7 +47,10 @@ async def worker(worker_id: int, cfg: object, pool: object) -> None:
debug_mode = logging.getLogger().getEffectiveLevel() == logging.DEBUG debug_mode = logging.getLogger().getEffectiveLevel() == logging.DEBUG
logger.info("Avviato") logger.info("Avviato")
alternatore = alterna_valori([WorkflowFlags.CSV_RECEIVED,WorkflowFlags.SENT_RAW_DATA], [WorkflowFlags.DATA_ELABORATED, WorkflowFlags.SENT_ELAB_DATA]) alternatore = alterna_valori(
[WorkflowFlags.CSV_RECEIVED, WorkflowFlags.SENT_RAW_DATA],
[WorkflowFlags.DATA_ELABORATED, WorkflowFlags.SENT_ELAB_DATA],
)
while True: while True:
try: try:
@@ -58,8 +66,8 @@ async def worker(worker_id: int, cfg: object, pool: object) -> None:
logger.info("Nessun record disponibile") logger.info("Nessun record disponibile")
await asyncio.sleep(NO_RECORD_SLEEP) await asyncio.sleep(NO_RECORD_SLEEP)
except Exception as e: except Exception as e: # pylint: disable=broad-except
logger.error(f"Errore durante l'esecuzione: {e}", exc_info=debug_mode) logger.error("Errore durante l'esecuzione: %s", e, exc_info=debug_mode)
await asyncio.sleep(1) await asyncio.sleep(1)
@@ -67,5 +75,6 @@ async def main():
"""Funzione principale che avvia il send_orchestrator.""" """Funzione principale che avvia il send_orchestrator."""
await run_orchestrator(setting.Config, worker) await run_orchestrator(setting.Config, worker)
if __name__ == "__main__": if __name__ == "__main__":
asyncio.run(main()) asyncio.run(main())