6817719400

Committed 09 Nov 2023 09:37PM UTC coverage: 56.744% (-0.004%) from 56.748%

Build # 6817719400

Build Type

push

github

Committed by

web-flow

Commit Message

RDMP-108 Unified UI Alerting from Processing Chunks (#1663)

* batched ui

* tidy up

* attempt to fix codeql

* fix linting

* add if check

* fix test

* add pragma

* fix up test

* update from codeql

* Update DataFlowPipelineEngine.cs

Tidy thread logic, fix double-disposal of objects

* Put chunk disposal in a finally block to avoid leaks

---------

Co-authored-by: James A Sutherland <j.a.sutherland@dundee.ac.uk>
Co-authored-by: James A Sutherland <>

Run Details

10700 of 20311 branches covered (0.0%)

Branch coverage included in aggregate %.

18 of 29 new or added lines in 1 file covered. (62.07%)

1 existing line in 1 file now uncovered.

30547 of 52379 relevant lines covered (58.32%)

7322.45 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

51.61

/Rdmp.Core/DataFlowPipeline/DataFlowPipelineEngine.cs

// Copyright (c) The University of Dundee 2018-2019
// This file is part of the Research Data Management Platform (RDMP).
// RDMP is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.
// RDMP is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
// You should have received a copy of the GNU General Public License along with RDMP. If not, see <https://www.gnu.org/licenses/>.

using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Data;
using System.Linq;
using System.Threading;
using Rdmp.Core.CommandExecution;
using Rdmp.Core.Curation.Data.Pipelines;
using Rdmp.Core.DataFlowPipeline.Requirements;
using Rdmp.Core.ReusableLibraryCode.Checks;
using Rdmp.Core.ReusableLibraryCode.Progress;

namespace Rdmp.Core.DataFlowPipeline;

/// <summary>
/// Generic implementation of IDataFlowPipelineEngine (See IDataFlowPipelineEngine).  You can create a DataFlowPipelineEngine by manually constructing the context,
/// source, destination etc but more often you will want to use an IPipeline configured by the user and an IPipelineUseCase to stamp out the pipeline into an instance
/// of the engine (See IDataFlowPipelineEngineFactory).  IPipeline is the user configured set of components they think will achieve a given task.
/// </summary>
/// <typeparam name="T"></typeparam>
public class DataFlowPipelineEngine<T> : IDataFlowPipelineEngine
{
    private readonly DataFlowPipelineContext<T> _context;
    private readonly IDataLoadEventListener _listener;

    private bool initialized;
    private string _name;

    /// <summary>
    /// Readonly cast of <see cref="ComponentObjects"/>. If you need to add components, add them to <see cref="ComponentObjects"/> instead.
    /// </summary>
    public ReadOnlyCollection<IDataFlowComponent<T>> Components =>
        ComponentObjects.Cast<IDataFlowComponent<T>>().ToList().AsReadOnly();

    /// <summary>
    /// The last component in the pipeline, responsible for writing the chunks (of type {T}) to somewhere (E.g. to disk, to database etc)
    /// </summary>
    public IDataFlowDestination<T> Destination { get; private set; }

    /// <summary>
    /// The first component in the pipeline, responsible for iteratively generating chunks (of type {T}) for feeding to downstream pipeline components
    /// </summary>
    public IDataFlowSource<T> Source { get; private set; }

    /// <summary>
    /// Middle components of the pipeline, must be <see cref="IDataFlowComponent{T}"/> with T appropriate to the context.
    /// </summary>
    public List<object> ComponentObjects { get; set; }

    /// <inheritdoc cref="Destination"/>
    public object DestinationObject => Destination;

    /// <inheritdoc cref="Source"/>
    public object SourceObject => Source;

    /// <summary>
    /// Creates a new pipeline engine ready to run under the <paramref name="context"/> recording events that occur to <paramref name="listener"/>.
    /// </summary>
    /// <param name="context"></param>
    /// <param name="source"></param>
    /// <param name="destination"></param>
    /// <param name="listener"></param>
    /// <param name="pipelineSource"></param>
    public DataFlowPipelineEngine(DataFlowPipelineContext<T> context, IDataFlowSource<T> source,
        IDataFlowDestination<T> destination, IDataLoadEventListener listener,
        IPipeline pipelineSource = null)
    {
        Source = source;
        Destination = destination;
        _context = context;
        _listener = listener;
        ComponentObjects = new List<object>();

        _name = pipelineSource != null ? pipelineSource.Name : "Undefined pipeline";
    }

    /// <inheritdoc/>
    public void Initialize(params object[] initializationObjects)
    {
        _context.PreInitialize(_listener, Source, initializationObjects);

        foreach (var component in Components)
            _context.PreInitialize(_listener, component, initializationObjects);

        _context.PreInitialize(_listener, Destination, initializationObjects);

        initialized = true;
    }

    private void UIAlert(string alert, IBasicActivateItems activator)
    {
        if (!activator.IsInteractive) return;

        new Thread(() =>
        {
            // run as a separate thread to not halt the UI
            activator.Show(alert);
        })
        {
            IsBackground = true
        }.Start();
    }

    /// <inheritdoc/>
    public void ExecutePipeline(GracefulCancellationToken cancellationToken)
    {
        Exception exception = null;
        try
        {
            _listener.OnNotify(this, new NotifyEventArgs(ProgressEventType.Debug, "Starting pipeline engine"));

            if (!initialized)
                throw new Exception(
                    "Engine has not been initialized, call Initialize(DataFlowPipelineContext context, params object[] initializationObjects");

            var hasMoreData = true;
            List<Tuple<string, IBasicActivateItems>> uiAlerts = new();
            while (!cancellationToken.IsCancellationRequested && hasMoreData)
                hasMoreData = ExecuteSinglePass(cancellationToken, uiAlerts);

            if (cancellationToken.IsAbortRequested)
            {
                Source.Abort(_listener);

                foreach (var c in Components)
                    c.Abort(_listener);

                Destination.Abort(_listener);

                _listener.OnNotify(this,
                    new NotifyEventArgs(ProgressEventType.Information, "Pipeline engine aborted"));
                return;
            }
            foreach (var alert in uiAlerts.Distinct().Where(static alert => alert is not null))
                UIAlert(alert.Item1, alert.Item2);
        }
        catch (Exception e)
        {
            exception = e;
            _listener.OnNotify(this, new NotifyEventArgs(ProgressEventType.Error, e.Message, e));
        }
        finally
        {
            _listener.OnNotify(this,
                new NotifyEventArgs(ProgressEventType.Debug,
                    "Preparing to Dispose of DataFlowPipelineEngine components"));

            _listener.OnNotify(this, new NotifyEventArgs(ProgressEventType.Trace, $"About to Dispose {Source}"));
            try
            {
                Source.Dispose(_listener, exception);
            }
            catch (Exception e)
            {
                //dispose crashing is only a dealbreaker if there wasn't already an exception in the pipeline
                if (exception == null)
                    throw;

                _listener.OnNotify(Source,
                    new NotifyEventArgs(ProgressEventType.Error, "Error Disposing Source Component", e));
            }

            foreach (var dataLoadComponent in Components)
            {
                _listener.OnNotify(this, new NotifyEventArgs(ProgressEventType.Trace,
                    $"About to Dispose {dataLoadComponent}"));
                try
                {
                    dataLoadComponent.Dispose(_listener, exception);
                }
                catch (Exception e)
                {
                    //dispose crashing is only a dealbreaker if there wasn't already an exception in the pipeline
                    if (exception == null)
                        throw;

                    _listener.OnNotify(dataLoadComponent,
                        new NotifyEventArgs(ProgressEventType.Error, "Error Disposing Component", e));
                }
            }

            _listener.OnNotify(this, new NotifyEventArgs(ProgressEventType.Trace, $"About to Dispose {Destination}"));
            try
            {
                Destination.Dispose(_listener, exception);
            }
            catch (Exception e)
            {
                //dispose crashing is only a dealbreaker if there wasn't already an exception in the pipeline
                if (exception == null)
                    throw;

                _listener.OnNotify(Destination,
                    new NotifyEventArgs(ProgressEventType.Error, "Error Disposing Destination Component", e));
            }
        }

        if (exception != null)
            throw new PipelineCrashedException("Data Flow Pipeline Crashed", exception);
    }

    /// <inheritdoc/>
    public bool ExecuteSinglePass(GracefulCancellationToken cancellationToken, List<Tuple<string, IBasicActivateItems>> completionUIAlerts = null)
    {
        if (!initialized)
            throw new Exception(
                "Engine has not been initialized, call Initialize(DataFlowPipelineContext context, params object[] initializationObjects");

        T currentChunk;
        try
        {
            currentChunk = Source.GetChunk(_listener, cancellationToken);
        }
        catch (OperationCanceledException)
        {
            throw;
        }
        catch (Exception e)
        {
            throw new InvalidOperationException(
                $"Error when attempting to get a chunk from the source component: {Source}", e);
        }
        if (currentChunk == null)
        {
            _listener.OnNotify(this,
                new NotifyEventArgs(ProgressEventType.Debug,
                    "Received null chunk from the Source component, stopping engine"));
            return false;
        }

        try {
          foreach (var component in Components)
          {
              if (cancellationToken.IsAbortRequested) break;

              currentChunk = component.ProcessPipelineData(currentChunk, _listener, cancellationToken);
              if (completionUIAlerts is not null && currentChunk is DataTable dt)
              {
                  var uiAlert = (Tuple<string, IBasicActivateItems>)dt.ExtendedProperties["AlertUIAtEndOfProcess"];
                  completionUIAlerts.Add(uiAlert);
              }
          }

          if (cancellationToken.IsAbortRequested) return true;

          Destination.ProcessPipelineData(currentChunk, _listener, cancellationToken);

          if (cancellationToken.IsAbortRequested) return true;
        }
        finally {
          //if it is a DataTable call .Clear() because Dispose doesn't actually free up any memory
          if (currentChunk is DataTable dt2)
              dt2.Clear();

          //if the chunk is something that can be disposed, dispose it (e.g. DataTable - to free up memory)
          if (currentChunk is IDisposable junk)
  #pragma warning disable
              junk.Dispose();
        }

        return true;
    }

    /// <summary>
    /// Runs checks on all components in the pipeline that support <see cref="ICheckable"/>
    /// </summary>
    /// <param name="notifier"></param>
    public void Check(ICheckNotifier notifier)
    {
        try
        {
            if (Source is ICheckable checkableSource)
            {
                notifier.OnCheckPerformed(new CheckEventArgs(
                    $"About to start checking Source component {checkableSource}",
                    CheckResult.Success));
                checkableSource.Check(notifier);
            }
            else
            {
                notifier.OnCheckPerformed(
                    new CheckEventArgs(
                        $"Source component {Source} does not support ICheckable so skipping checking it",
                        CheckResult.Warning));
            }

            foreach (var component in Components)
                if (component is ICheckable checkable)
                {
                    notifier.OnCheckPerformed(new CheckEventArgs($"About to start checking component {component}",
                        CheckResult.Success));
                    checkable.Check(notifier);
                }
                else
                {
                    notifier.OnCheckPerformed(
                        new CheckEventArgs(
                            $"Component {component} does not support ICheckable so skipping checking it",
                            CheckResult.Warning));
                }

            if (Destination is ICheckable checkableDestination)
            {
                notifier.OnCheckPerformed(new CheckEventArgs(
                    $"About to start checking Destination component {checkableDestination}",
                    CheckResult.Success));
                checkableDestination.Check(notifier);
            }
            else
            {
                notifier.OnCheckPerformed(
                    new CheckEventArgs(
                        $"Destination component {Destination} does not support ICheckable so skipping checking it",
                        CheckResult.Warning));
            }
        }
        catch (Exception e)
        {
            notifier.OnCheckPerformed(
                new CheckEventArgs(
                    $"{typeof(DataFlowPipelineEngine<T>).Name} Checking failed in an unexpected way",
                    CheckResult.Fail, e));
        }


        notifier.OnCheckPerformed(new CheckEventArgs("Finished checking all components", CheckResult.Success));
    }

    /// <inheritdoc/>
    public override string ToString() => _name;
}

1	// Copyright (c) The University of Dundee 2018-2019
2	// This file is part of the Research Data Management Platform (RDMP).
3	// RDMP is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.
4	// RDMP is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
5	// You should have received a copy of the GNU General Public License along with RDMP. If not, see <https://www.gnu.org/licenses/>.
6
7	using System;
8	using System.Collections.Generic;
9	using System.Collections.ObjectModel;
10	using System.Data;
11	using System.Linq;
12	using System.Threading;
13	using Rdmp.Core.CommandExecution;
14	using Rdmp.Core.Curation.Data.Pipelines;
15	using Rdmp.Core.DataFlowPipeline.Requirements;
16	using Rdmp.Core.ReusableLibraryCode.Checks;
17	using Rdmp.Core.ReusableLibraryCode.Progress;
18
19	namespace Rdmp.Core.DataFlowPipeline;
20
21	/// <summary>
22	/// Generic implementation of IDataFlowPipelineEngine (See IDataFlowPipelineEngine). You can create a DataFlowPipelineEngine by manually constructing the context,
23	/// source, destination etc but more often you will want to use an IPipeline configured by the user and an IPipelineUseCase to stamp out the pipeline into an instance
24	/// of the engine (See IDataFlowPipelineEngineFactory). IPipeline is the user configured set of components they think will achieve a given task.
25	/// </summary>
26	/// <typeparam name="T"></typeparam>
27	public class DataFlowPipelineEngine<T> : IDataFlowPipelineEngine
28	{
29	private readonly DataFlowPipelineContext<T> _context;
30	private readonly IDataLoadEventListener _listener;
31
32	private bool initialized;
33	private string _name;
34
35	/// <summary>
36	/// Readonly cast of <see cref="ComponentObjects"/>. If you need to add components, add them to <see cref="ComponentObjects"/> instead.
37	/// </summary>
38	public ReadOnlyCollection<IDataFlowComponent<T>> Components =>
39	ComponentObjects.Cast<IDataFlowComponent<T>>().ToList().AsReadOnly();	488✔
40
41	/// <summary>
42	/// The last component in the pipeline, responsible for writing the chunks (of type {T}) to somewhere (E.g. to disk, to database etc)
43	/// </summary>
44	public IDataFlowDestination<T> Destination { get; private set; }	868✔
45
46	/// <summary>
47	/// The first component in the pipeline, responsible for iteratively generating chunks (of type {T}) for feeding to downstream pipeline components
48	/// </summary>
49	public IDataFlowSource<T> Source { get; private set; }	998✔
50
51	/// <summary>
52	/// Middle components of the pipeline, must be <see cref="IDataFlowComponent{T}"/> with T appropriate to the context.
53	/// </summary>
54	public List<object> ComponentObjects { get; set; }	758✔
55
56	/// <inheritdoc cref="Destination"/>
57	public object DestinationObject => Destination;	72✔
58
59	/// <inheritdoc cref="Source"/>
60	public object SourceObject => Source;	54✔
61
62	/// <summary>
63	/// Creates a new pipeline engine ready to run under the <paramref name="context"/> recording events that occur to <paramref name="listener"/>.
64	/// </summary>
65	/// <param name="context"></param>
66	/// <param name="source"></param>
67	/// <param name="destination"></param>
68	/// <param name="listener"></param>
69	/// <param name="pipelineSource"></param>
70	public DataFlowPipelineEngine(DataFlowPipelineContext<T> context, IDataFlowSource<T> source,	168✔
71	IDataFlowDestination<T> destination, IDataLoadEventListener listener,	168✔
72	IPipeline pipelineSource = null)	168✔
73	{
74	Source = source;	168✔
75	Destination = destination;	168✔
76	_context = context;	168✔
77	_listener = listener;	168✔
78	ComponentObjects = new List<object>();	168✔
79
80	_name = pipelineSource != null ? pipelineSource.Name : "Undefined pipeline";	168✔
81	}	168✔
82
83	/// <inheritdoc/>
84	public void Initialize(params object[] initializationObjects)
85	{
86	_context.PreInitialize(_listener, Source, initializationObjects);	168✔
87
88	foreach (var component in Components)	540✔
89	_context.PreInitialize(_listener, component, initializationObjects);	102✔
90
91	_context.PreInitialize(_listener, Destination, initializationObjects);	168✔
92
93	initialized = true;	168✔
94	}	168✔
95
96	private void UIAlert(string alert, IBasicActivateItems activator)
97	{
NEW 98	if (!activator.IsInteractive) return;	×
99
NEW 100	new Thread(() =>	×
NEW 101	{	×
NEW 102	// run as a separate thread to not halt the UI	×
NEW 103	activator.Show(alert);	×
NEW 104	})	×
NEW 105	{	×
NEW 106	IsBackground = true	×
NEW 107	}.Start();	×
NEW 108	}	×
109
110	/// <inheritdoc/>
111	public void ExecutePipeline(GracefulCancellationToken cancellationToken)
112	{
113	Exception exception = null;	140✔
114	try
115	{
116	_listener.OnNotify(this, new NotifyEventArgs(ProgressEventType.Debug, "Starting pipeline engine"));	140✔
117
118	if (!initialized)	140!
119	throw new Exception(	×
120	"Engine has not been initialized, call Initialize(DataFlowPipelineContext context, params object[] initializationObjects");	×
121
122	var hasMoreData = true;	140✔
123	List<Tuple<string, IBasicActivateItems>> uiAlerts = new();	140✔
124	while (!cancellationToken.IsCancellationRequested && hasMoreData)	420✔
125	hasMoreData = ExecuteSinglePass(cancellationToken, uiAlerts);	284✔
126
127	if (cancellationToken.IsAbortRequested)	136!
128	{
129	Source.Abort(_listener);	×
130
131	foreach (var c in Components)	×
132	c.Abort(_listener);	×
133
134	Destination.Abort(_listener);	×
135
136	_listener.OnNotify(this,	×
137	new NotifyEventArgs(ProgressEventType.Information, "Pipeline engine aborted"));	×
138	return;	×
139	}
140	foreach (var alert in uiAlerts.Distinct().Where(static alert => alert is not null))	326!
NEW 141	UIAlert(alert.Item1, alert.Item2);	×
142	}	136✔
143	catch (Exception e)	4✔
144	{
145	exception = e;	4✔
146	_listener.OnNotify(this, new NotifyEventArgs(ProgressEventType.Error, e.Message, e));	4✔
147	}	4✔
148	finally
149	{
150	_listener.OnNotify(this,	140✔
151	new NotifyEventArgs(ProgressEventType.Debug,	140✔
152	"Preparing to Dispose of DataFlowPipelineEngine components"));	140✔
153
154	_listener.OnNotify(this, new NotifyEventArgs(ProgressEventType.Trace, $"About to Dispose {Source}"));	140✔
155	try
156	{
157	Source.Dispose(_listener, exception);	140✔
158	}	140✔
159	catch (Exception e)	×
160	{
161	//dispose crashing is only a dealbreaker if there wasn't already an exception in the pipeline
162	if (exception == null)	×
163	throw;	×
164
165	_listener.OnNotify(Source,	×
166	new NotifyEventArgs(ProgressEventType.Error, "Error Disposing Source Component", e));	×
167	}	×
168
169	foreach (var dataLoadComponent in Components)	484✔
170	{
171	_listener.OnNotify(this, new NotifyEventArgs(ProgressEventType.Trace,	102✔
172	$"About to Dispose {dataLoadComponent}"));	102✔
173	try
174	{
175	dataLoadComponent.Dispose(_listener, exception);	102✔
176	}	102✔
177	catch (Exception e)	×
178	{
179	//dispose crashing is only a dealbreaker if there wasn't already an exception in the pipeline
180	if (exception == null)	×
181	throw;	×
182
183	_listener.OnNotify(dataLoadComponent,	×
184	new NotifyEventArgs(ProgressEventType.Error, "Error Disposing Component", e));	×
185	}	×
186	}
187
188	_listener.OnNotify(this, new NotifyEventArgs(ProgressEventType.Trace, $"About to Dispose {Destination}"));	140✔
189	try
190	{
191	Destination.Dispose(_listener, exception);	140✔
192	}	140✔
193	catch (Exception e)	×
194	{
195	//dispose crashing is only a dealbreaker if there wasn't already an exception in the pipeline
196	if (exception == null)	×
197	throw;	×
198
199	_listener.OnNotify(Destination,	×
200	new NotifyEventArgs(ProgressEventType.Error, "Error Disposing Destination Component", e));	×
201	}	×
202	}	140✔
203
204	if (exception != null)	140✔
205	throw new PipelineCrashedException("Data Flow Pipeline Crashed", exception);	4✔
206	}	136✔
207
208	/// <inheritdoc/>
209	public bool ExecuteSinglePass(GracefulCancellationToken cancellationToken, List<Tuple<string, IBasicActivateItems>> completionUIAlerts = null)
210	{
211	if (!initialized)	324!
212	throw new Exception(	×
213	"Engine has not been initialized, call Initialize(DataFlowPipelineContext context, params object[] initializationObjects");	×
214
215	T currentChunk;
216	try
217	{
218	currentChunk = Source.GetChunk(_listener, cancellationToken);	324✔
219	}	320✔
220	catch (OperationCanceledException)	×
221	{
222	throw;	×
223	}
224	catch (Exception e)	4✔
225	{
226	throw new InvalidOperationException(	4✔
227	$"Error when attempting to get a chunk from the source component: {Source}", e);	4✔
228	}
229	if (currentChunk == null)	320✔
230	{
231	_listener.OnNotify(this,	140✔
232	new NotifyEventArgs(ProgressEventType.Debug,	140✔
233	"Received null chunk from the Source component, stopping engine"));	140✔
234	return false;	140✔
235	}
236
237	try {
238	foreach (var component in Components)	564✔
239	{
240	if (cancellationToken.IsAbortRequested) break;	102!
241
242	currentChunk = component.ProcessPipelineData(currentChunk, _listener, cancellationToken);	102✔
243	if (completionUIAlerts is not null && currentChunk is DataTable dt)	102✔
244	{
245	var uiAlert = (Tuple<string, IBasicActivateItems>)dt.ExtendedProperties["AlertUIAtEndOfProcess"];	100✔
246	completionUIAlerts.Add(uiAlert);	100✔
247	}
248	}
249
250	if (cancellationToken.IsAbortRequested) return true;	180!
251
252	Destination.ProcessPipelineData(currentChunk, _listener, cancellationToken);	180✔
253
254	if (cancellationToken.IsAbortRequested) return true;	180!
255	}	180✔
256	finally {
257	//if it is a DataTable call .Clear() because Dispose doesn't actually free up any memory
258	if (currentChunk is DataTable dt2)	180✔
259	dt2.Clear();	134✔
260
261	//if the chunk is something that can be disposed, dispose it (e.g. DataTable - to free up memory)
262	if (currentChunk is IDisposable junk)	180✔
263	#pragma warning disable
264	junk.Dispose();	134✔
265	}	180✔
266
267	return true;	180✔
UNCOV 268	}	×
269
270	/// <summary>
271	/// Runs checks on all components in the pipeline that support <see cref="ICheckable"/>
272	/// </summary>
273	/// <param name="notifier"></param>
274	public void Check(ICheckNotifier notifier)
275	{
276	try
277	{
278	if (Source is ICheckable checkableSource)	×
279	{
280	notifier.OnCheckPerformed(new CheckEventArgs(	×
281	$"About to start checking Source component {checkableSource}",	×
282	CheckResult.Success));	×
283	checkableSource.Check(notifier);	×
284	}
285	else
286	{
287	notifier.OnCheckPerformed(	×
288	new CheckEventArgs(	×
289	$"Source component {Source} does not support ICheckable so skipping checking it",	×
290	CheckResult.Warning));	×
291	}
292
293	foreach (var component in Components)	×
294	if (component is ICheckable checkable)	×
295	{
296	notifier.OnCheckPerformed(new CheckEventArgs($"About to start checking component {component}",	×
297	CheckResult.Success));	×
298	checkable.Check(notifier);	×
299	}
300	else
301	{
302	notifier.OnCheckPerformed(	×
303	new CheckEventArgs(	×
304	$"Component {component} does not support ICheckable so skipping checking it",	×
305	CheckResult.Warning));	×
306	}
307
308	if (Destination is ICheckable checkableDestination)	×
309	{
310	notifier.OnCheckPerformed(new CheckEventArgs(	×
311	$"About to start checking Destination component {checkableDestination}",	×
312	CheckResult.Success));	×
313	checkableDestination.Check(notifier);	×
314	}
315	else
316	{
317	notifier.OnCheckPerformed(	×
318	new CheckEventArgs(	×
319	$"Destination component {Destination} does not support ICheckable so skipping checking it",	×
320	CheckResult.Warning));	×
321	}
322	}	×
323	catch (Exception e)	×
324	{
325	notifier.OnCheckPerformed(	×
326	new CheckEventArgs(	×
327	$"{typeof(DataFlowPipelineEngine<T>).Name} Checking failed in an unexpected way",	×
328	CheckResult.Fail, e));	×
329	}	×
330
331
332	notifier.OnCheckPerformed(new CheckEventArgs("Finished checking all components", CheckResult.Success));	×
333	}	×
334
335	/// <inheritdoc/>
336	public override string ToString() => _name;	×
337	}

HicServices / RDMP / 6817719400

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous