diff options
Diffstat (limited to 'python/ack_checker.py')
| -rw-r--r-- | python/ack_checker.py | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/python/ack_checker.py b/python/ack_checker.py index 4844fa72..012bc6fb 100644 --- a/python/ack_checker.py +++ b/python/ack_checker.py @@ -5,6 +5,8 @@ from csv import reader from io import BytesIO from serenitas.utils.remote import SftpClient, FtpClient from serenitas.utils.db import dbconn +from serenitas.utils import SerenitasFileHandler +import logging def serenitas_files(date): @@ -27,6 +29,10 @@ def bowdst_files(date): def ack_check(date: datetime.date, conn): + logger = logging.getLogger(__name__) + fh = SerenitasFileHandler("truload.log") + logger.addHandler(fh) + logger.setLevel(logging.INFO) files = list(serenitas_files(date)) + list(bowdst_files(date)) for f in files: csv = reader(f) @@ -67,6 +73,8 @@ def ack_check(date: datetime.date, conn): "UPDATE spots SET globeop_id=%s WHERE id=%s", (globeop_id, serenitas_id), ) + elif action == "Failed": + logger.warning(f"{serenitas_id} ({action}): {globeop_id} ") conn.commit() |