aboutsummaryrefslogtreecommitdiffstats
path: root/python/process_queue.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/process_queue.py')
-rw-r--r--python/process_queue.py39
1 files changed, 16 insertions, 23 deletions
diff --git a/python/process_queue.py b/python/process_queue.py
index 3720b8a0..e419b0eb 100644
--- a/python/process_queue.py
+++ b/python/process_queue.py
@@ -342,11 +342,6 @@ def build_line(obj, trade_type="bond", fund="SERCGMAST"):
"transaction_indicator": "TransactionIndicator",
},
)
- if fund == "BOWDST":
- obj["Folder"] = "HEDGEMARK_TEST/Strategy-BOS_PAT_BOWDOIN"
- obj["Custodian"] = "TEST"
- obj["Cash Account"] = "TELHEEACPB"
- obj["Counterparty"] = "TESTLN"
return [obj.get(h, None) for h in get_headers(trade_type, fund)]
@@ -687,24 +682,22 @@ def upload_buf(
sftp = SftpClient.from_creds("hm_globeop")
sftp.client.chdir("incoming")
sftp.put(buf, dest)
- # sftp.client.chdir("/inbound/cfe/")
- # sftp.put(buf, dest, False)
- # em = ExchangeMessage()
- # recipients = (
- # "caagtradecapture@bnymellon.com",
- # "hm-operations@bnymellon.com",
- # "caagprim@bnymellon.com",
- # "julie.picariello@bnymellon.com",
- # )
- # if trade_type in ("cds", "swaption"):
- # recipients += ("sa1futures.optionsprocessing@bnymellon.com",)
- # em.send_email(
- # "Trade file",
- # "",
- # to_recipients=recipients,
- # cc_recipients=("bowdoin-ops@lmcg.com",),
- # attach=(FileAttachment(name=dest, content=buf),),
- # )
+ em = ExchangeMessage()
+ recipients = (
+ "caagtradecapture@bnymellon.com",
+ "hm-operations@bnymellon.com",
+ "caagprim@bnymellon.com",
+ "julie.picariello@bnymellon.com",
+ )
+ if trade_type in ("cds", "swaption"):
+ recipients += ("sa1futures.optionsprocessing@bnymellon.com",)
+ em.send_email(
+ "Trade file",
+ "",
+ to_recipients=recipients,
+ cc_recipients=("bowdoin-ops@lmcg.com",),
+ attach=(FileAttachment(name=dest, content=buf),),
+ )
else:
raise ValueError(f"unknow fund name: {fund}")