1 files changed, 4 insertions, 2 deletions
diff --git a/python/task_server/globeop.py b/python/task_server/globeop.py
index 76ef0052..127b58a3 100644
--- a/python/task_server/globeop.py
+++ b/python/task_server/globeop.py
@@ -119,8 +119,10 @@ def download_data(workdate):
     for report in ["Valuation", "Pnl", "CDS"]:
         fun = getattr(load_globeop_report, "read_{}_report".format(report.lower()))
         table = "{}_reports".format(report.lower())
-
-        df = fun(os.path.join(reports_dir, "{}_Report.csv".format(report)))
+        report_file = os.path.join(reports_dir, "{}_Report.csv".format(report))
+        if not os.path.exists(report_file):
+            continue
+        df = fun(report_file)
         if report == "Valuation":
             period_end_date = pd.Timestamp(df.periodenddate[0])
             sql_str = "DELETE FROM valuation_reports WHERE periodenddate=%s"