aboutsummaryrefslogtreecommitdiffstats
path: root/python
diff options
context:
space:
mode:
Diffstat (limited to 'python')
-rw-r--r--python/collateral/baml_fcm.py7
-rw-r--r--python/collateral/wells.py9
2 files changed, 6 insertions, 10 deletions
diff --git a/python/collateral/baml_fcm.py b/python/collateral/baml_fcm.py
index b6bfddfb..65ab758d 100644
--- a/python/collateral/baml_fcm.py
+++ b/python/collateral/baml_fcm.py
@@ -1,13 +1,12 @@
from . import DAILY_DIR, SftpClient
from .common import compare_notionals, STRATEGY_CASH_MAPPING
-from functools import partial
import pandas as pd
from sqlalchemy.exc import IntegrityError
-sftp = SftpClient.from_creds("baml_fcm")
-
-download_files = partial(sftp.download_files, "outgoing", DAILY_DIR / "BAML_reports")
+def download_files(**args):
+ sftp = SftpClient.from_creds("baml_fcm")
+ sftp.download_files("outgoing", DAILY_DIR / "BAML_reports")
def collateral(d, positions, engine):
diff --git a/python/collateral/wells.py b/python/collateral/wells.py
index e47142ee..e9065c88 100644
--- a/python/collateral/wells.py
+++ b/python/collateral/wells.py
@@ -1,15 +1,12 @@
import pandas as pd
from . import DAILY_DIR, SftpClient2
from .common import compare_notionals, STRATEGY_CASH_MAPPING
-from functools import partial
from sqlalchemy.exc import IntegrityError
-sftp = SftpClient2.from_creds("wells")
-
-download_files = partial(
- sftp.download_files, "/RECEIVE/339425_DATO2", DAILY_DIR / "Wells_reports"
-)
+def download_files(**args):
+ sftp = SftpClient2.from_creds("wells")
+ sftp.download_files("/RECEIVE/339425_DATO2", DAILY_DIR / "Wells_reports")
def collateral(d, positions, engine):