diff options
Diffstat (limited to 'python/ctm_allocation.py')
| -rw-r--r-- | python/ctm_allocation.py | 11 |
1 files changed, 4 insertions, 7 deletions
diff --git a/python/ctm_allocation.py b/python/ctm_allocation.py index b39bab24..c8929d39 100644 --- a/python/ctm_allocation.py +++ b/python/ctm_allocation.py @@ -6,12 +6,8 @@ from io import StringIO import datetime import argparse from pandas.tseries.offsets import BDay -import sys - -sys.path.append("/home/flint/projects/") -from ops.serenitas.ops.trade_dataclasses import BondDeal -from ops.serenitas.ops.funds import CTM - +from serenitas.ops.trade_dataclasses import BondDeal +from serenitas.ops.funds import CTM if __name__ == "__main__": parser = argparse.ArgumentParser() @@ -31,7 +27,7 @@ if __name__ == "__main__": } df = pd.read_sql_query( - "SELECT ba.id, allocated, emailed FROM bonds LEFT JOIN bond_allocation ba ON bonds.id=ba.tradeid WHERE trade_date=%s;", + "SELECT ba.id, allocated, emailed FROM bonds LEFT JOIN bond_allocation ba ON bonds.id=ba.tradeid LEFT JOIN counterparties c ON cp_code=c.code WHERE trade_date=%s AND ctm_code IS NOT null;", con=dawn_engine, params=(args.trade_date,), ) @@ -39,3 +35,4 @@ if __name__ == "__main__": for row in df.itertuples(): CTM.stage(BondDeal.from_allocationid(row.id)) buf, dest = CTM.build_buffer() + # CTM.upload(buf) |