diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/quote_diff_bowdst.py | 24 |
1 files changed, 18 insertions, 6 deletions
diff --git a/python/quote_diff_bowdst.py b/python/quote_diff_bowdst.py index 48f64141..f075f1c7 100644 --- a/python/quote_diff_bowdst.py +++ b/python/quote_diff_bowdst.py @@ -7,6 +7,9 @@ from io import StringIO from exchangelib import FileAttachment import argparse +from serenitas.utils import SerenitasFileHandler +import logging + conn = dbconn("dawndb") parser = argparse.ArgumentParser(description="determine sender destination") @@ -14,6 +17,16 @@ parser.add_argument("--globeop", action="store_true", help="send to globeop") args = parser.parse_args() +args = parser.parse_args() + + +logger = logging.getLogger(__name__) +if not logger.handlers: + fh = SerenitasFileHandler("quote_diff_bowdst.log") + logger.addHandler(fh) +logger.setLevel(logging.INFO) + + with conn.cursor() as c: df = pd.read_sql( sql="SELECT * FROM list_bowd_quotes(%s)", @@ -21,13 +34,11 @@ with conn.cursor() as c: params=(datetime.date.today() - datetime.timedelta(1),), ) try: - diff = df[~np.isclose(df["bowd_price"], df["closeprice"], atol=0.15)].rename( - mapper={"closeprice": "our_price"}, axis=1 - ) - except TypeError: - breakpoint() + mask = np.isclose(df["bowd_price"], df["closeprice"], atol=0.15) + diff = df[~mask].rename(mapper={"closeprice": "our_price"}, axis=1) + except TypeError as e: + logger.error(e) else: - if not diff.empty: buf = StringIO() diff.to_csv(buf, index=False) @@ -66,3 +77,4 @@ with conn.cursor() as c: cc_recipients=cc_recipients, attach=attachments, ) + logger.info(diff) |