1 files changed, 4 insertions, 4 deletions
diff --git a/python/task_server/globeop.py b/python/task_server/globeop.py
index 0b9747cd..0fa225dc 100644
--- a/python/task_server/globeop.py
+++ b/python/task_server/globeop.py
@@ -205,14 +205,14 @@ def upload_bond_marks(engine, workdate: datetime.datetime, fund):
         ),
     )
     df.rename(columns={"identifier": "IDENTIFIER", "price": "Price"}, inplace=True)
-    fullpath = DAILY_DIR / str(d) / f"securitiesNpv{workdate:%Y%m%d_%H%M%S}.csv"
+    fullpath = DAILY_DIR / str(d) / f"securitiesNpv{workdate:%Y%m%d_%H%M%S}_{fund}.csv"
     df.to_csv(fullpath, index=False)
     match fund:
         case "SERCGMAST":
             server = FtpClient.from_creds("globeop", folder="incoming")
         case "BOWDST":
             server = SftpClient.from_creds("hm_globeop", folder="incoming/gopricing")
-    server.put(fullpath)
+    server.put(fullpath, f"securitiesNpv{workdate:%Y%m%d_%H%M%S}.csv")
     logger.info("upload bond marks done")
 
 
@@ -228,14 +228,14 @@ JOIN cds USING (security_id)""",
             fund,
         ),
     )
-    fullpath = DAILY_DIR / str(d) / f"otcNpv{workdate:%Y%m%d}.csv"
+    fullpath = DAILY_DIR / str(d) / f"otcNpv{workdate:%Y%m%d}_{fund}.csv"
     df.to_csv(fullpath, index=False)
     match fund:
         case "SERCGMAST":
             server = FtpClient.from_creds("globeop", folder="incoming")
         case "BOWDST":
             server = SftpClient.from_creds("hm_globeop", folder="incoming/gopricing")
-    server.put(fullpath)
+    server.put(fullpath, f"otcNpv{workdate:%Y%m%d}.csv")
     logger.info("upload cds marks done")