diff --git a/DataProcessing/Program.cs b/DataProcessing/Program.cs index 5656130..7bb4b0c 100644 --- a/DataProcessing/Program.cs +++ b/DataProcessing/Program.cs @@ -63,7 +63,10 @@ public static void Main() $"{VendorName} {QuiverCNBCDataDownloader.VendorDataName} data for date: {date:yyyy-MM-dd}"); } } - instance.Flush(); + if (!instance.Flush()) + { + return false; + } instance.ProcessUniverse(); return true; }); @@ -138,7 +141,10 @@ public static void Main() $"{VendorName} {QuiverInsiderTradingDataDownloader.VendorDataName} data for date: {date:yyyy-MM-dd}"); } } - instance.Flush(); + if (!instance.Flush()) + { + return false; + } instance.ProcessUniverse(); return true; }); diff --git a/DataProcessing/QuiverCNBCDataDownloader.cs b/DataProcessing/QuiverCNBCDataDownloader.cs index e40032b..54295dc 100644 --- a/DataProcessing/QuiverCNBCDataDownloader.cs +++ b/DataProcessing/QuiverCNBCDataDownloader.cs @@ -141,6 +141,12 @@ public bool Run(DateTime processDate) /// True on success public bool Flush() { + if (_cnbcByTicker.Count == 0) + { + Log.Error($"QuiverCNBCDataDownloader.Flush(): No data accumulated; treating run as a failure (likely unable to reach QuiverQuant)."); + return false; + } + try { foreach (var kvp in _cnbcByTicker) diff --git a/DataProcessing/QuiverInsiderTradingDataDownloader.cs b/DataProcessing/QuiverInsiderTradingDataDownloader.cs index f091c33..291a282 100644 --- a/DataProcessing/QuiverInsiderTradingDataDownloader.cs +++ b/DataProcessing/QuiverInsiderTradingDataDownloader.cs @@ -165,6 +165,12 @@ public bool Run(DateTime processDate) /// True on success public bool Flush() { + if (_insiderTradingByTicker.Count == 0) + { + Log.Error($"QuiverInsiderTradingDataDownloader.Flush(): No data accumulated; treating run as a failure (likely unable to reach QuiverQuant)."); + return false; + } + var failed = 0; foreach (var kvp in _insiderTradingByTicker) {