Report error on run start (#135)

* Catch and report errors when starting extraction run. * Add better logging on startup
cognitedata · Oct 26, 2021 · 0eeb6e9 · 0eeb6e9
1 parent 25510de
commit 0eeb6e9
Showing 1 changed file with 15 additions and 2 deletions.
diff --git a/ExtractorUtils/ExtractionRun.cs b/ExtractorUtils/ExtractionRun.cs
@@ -3,6 +3,7 @@
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Logging.Abstractions;
 using System;
+using System.Collections.Generic;
 using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
@@ -69,15 +70,27 @@ public void Start()
 
         private async Task Run()
         {
-            var pipe = await _destination.CogniteClient.ExtPipes.RetrieveAsync(
-                new[] { Identity.Create(_config.PipelineId) }, true, _source.Token).ConfigureAwait(false);
+            IEnumerable<ExtPipe> pipe;
+            try
+            {
+                pipe = await _destination.CogniteClient.ExtPipes.RetrieveAsync(
+                    new[] { Identity.Create(_config.PipelineId) }, true, _source.Token).ConfigureAwait(false);
+            }
+            catch (Exception ex)
+            {
+                _log.LogError("Failed to fetch extraction pipeline with ExternalId: {id}, this extractor will not report status: {msg}",
+                    _config.PipelineId, ex.Message);
+                return;
+            }
+
             if (!pipe.Any())
             {
                 _log.LogError("Did not find extraction pipeline with ExternalId: {id}, this extractor will not report status",
                     _config.PipelineId);
                 return;
             }
 
+            _log.LogInformation("Begin reporting extraction runs to pipeline with id {id}. Continuous: {cont}", _config.PipelineId, Continuous);
             if (Continuous)
             {
                 try