diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/trade_dataclasses.py | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/python/trade_dataclasses.py b/python/trade_dataclasses.py index 180575e5..405ff37e 100644 --- a/python/trade_dataclasses.py +++ b/python/trade_dataclasses.py @@ -389,7 +389,7 @@ class BbgDeal: class MTMDeal: _mtm_queue: ClassVar[list] = [] _mtm_headers = None - _sftp = SftpClient.from_creds("mtm") + _mtm_sftp = SftpClient.from_creds("mtm") product_type: str def __init_subclass__(cls, deal_type, **kwargs): @@ -416,7 +416,7 @@ class MTMDeal: ) buf = buf.getvalue().encode() fname = f"MTM.{datetime.datetime.now():%Y%m%d.%H%M%S}.{cls.product_type.capitalize()}.csv" - cls._sftp.put(buf, fname) + cls._mtm_sftp.put(buf, fname) dest = DAILY_DIR / str(datetime.date.today()) / fname dest.write_bytes(buf) cls._mtm_queue.clear() @@ -431,7 +431,7 @@ class MTMDeal: class Citco: _citco_headers = [] - _sftp = SftpClient.from_creds("citco") + _citco_sftp = SftpClient.from_creds("citco") @classmethod def citco_upload(cls): @@ -451,8 +451,8 @@ class Citco: [row.get(h, None) for h in cls._citco_headers] for row in cls._citco_queue ) buf = buf.getvalue().encode() - cls._sftp.client.chdir("/incoming") - cls._sftp.put(buf, cls.fname()) + cls._citco_sftp.client.chdir("/incoming") + cls._citco_sftp.put(buf, cls.fname()) dest = DAILY_DIR / str(datetime.date.today()) / cls.fname() dest.write_bytes(buf) cls._citco_queue.clear() |