@@ -45,27 +45,28 @@ public void TraceBlockCompletion(IDataflowBlock block, string name)
45
45
break ;
46
46
}
47
47
Logger . LogTrace ( Context . Parameters , $ "{ GetType ( ) . Name } | ✅ Dataflow block completion task completed | { name } ({ block . GetType ( ) . Name } ) | { status } ") ;
48
- } )
49
- . ContinueWith ( t =>
50
- {
51
- var details = Blocks . Select (
52
- block => $ "{ ( block . Value . Completion . IsCompletedSuccessfully ? "✔️" :
53
- block . Value . Completion . IsFaulted ? "✖️" :
54
- block . Value . Completion . IsCanceled ? "⛔" : "🕑" ) } { block . Key } : { block . Value . Completion . Status } " ) ;
55
- Logger . LogTrace ( Context . Parameters , "Pipeline block completion status details" + Environment . NewLine + string . Join ( Environment . NewLine , details ) ) ;
56
- } ) ) ;
48
+ } ) . ContinueWith ( t =>
49
+ {
50
+ var details = Blocks . Select (
51
+ block => $ "{ (
52
+ block . Value . Completion . IsCompletedSuccessfully ? "✔️"
53
+ : block . Value . Completion . IsFaulted ? "✖️"
54
+ : block . Value . Completion . IsCanceled ? "⛔"
55
+ : "🕑" ) } { block . Key } : { block . Value . Completion . Status } " ) ;
56
+ Logger . LogTrace ( Context . Parameters , "Pipeline block completion status details" + Environment . NewLine + string . Join ( Environment . NewLine , details ) ) ;
57
+ } ) ) ;
57
58
}
58
59
59
60
public void FaultPipelineBlock ( IDataflowBlock block , Exception exception )
60
61
{
62
+ block . Fault ( exception ) ;
63
+ Logger . LogWarning ( Context . Parameters , $ "{ GetType ( ) . Name } | ⚠️ Block ({ block . GetType ( ) . Name } ) was faulted") ;
64
+
61
65
if ( Exception is null )
62
66
{
63
67
Exception = exception ;
64
68
Result . AddException ( exception ) ;
65
69
66
- block . Fault ( exception ) ;
67
- Logger . LogWarning ( Context . Parameters , $ "{ GetType ( ) . Name } | ⚠️ Block ({ block . GetType ( ) . Name } ) was faulted") ;
68
-
69
70
try
70
71
{
71
72
Logger . LogWarning ( Context . Parameters , $ "{ GetType ( ) . Name } | ⚠️ Cancelling token source") ;
@@ -77,6 +78,10 @@ public void FaultPipelineBlock(IDataflowBlock block, Exception exception)
77
78
Logger . LogWarning ( Context . Parameters , $ "{ GetType ( ) . Name } | ⚠️ Token source disposed: cancellation already happened") ;
78
79
}
79
80
}
81
+ else
82
+ {
83
+ Exception = new AggregateException ( [ Exception , exception ] ) ;
84
+ }
80
85
}
81
86
82
87
protected void ThrowIfCancellationRequested ( ) => Token . ThrowIfCancellationRequested ( ) ;
0 commit comments