From f9bb6b153ca4f90fdc3867250e06576d2eaab6f8 Mon Sep 17 00:00:00 2001 From: Nicolas Constant Date: Sat, 1 Aug 2020 19:26:00 -0400 Subject: [PATCH] make sure pipeline error are seen --- src/BirdsiteLive.Pipeline/StatusPublicationPipeline.cs | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/BirdsiteLive.Pipeline/StatusPublicationPipeline.cs b/src/BirdsiteLive.Pipeline/StatusPublicationPipeline.cs index 0e0da40..bcb896f 100644 --- a/src/BirdsiteLive.Pipeline/StatusPublicationPipeline.cs +++ b/src/BirdsiteLive.Pipeline/StatusPublicationPipeline.cs @@ -42,16 +42,16 @@ namespace BirdsiteLive.Pipeline // Link pipeline twitterUsersBufferBlock.LinkTo(retrieveTweetsBlock, new DataflowLinkOptions {PropagateCompletion = true}); - retrieveTweetsBlock.LinkTo(retrieveTweetsBufferBlock); - retrieveTweetsBufferBlock.LinkTo(retrieveFollowersBlock); - retrieveFollowersBlock.LinkTo(retrieveFollowersBufferBlock); - retrieveFollowersBufferBlock.LinkTo(sendTweetsToFollowersBlock); + retrieveTweetsBlock.LinkTo(retrieveTweetsBufferBlock, new DataflowLinkOptions { PropagateCompletion = true }); + retrieveTweetsBufferBlock.LinkTo(retrieveFollowersBlock, new DataflowLinkOptions { PropagateCompletion = true }); + retrieveFollowersBlock.LinkTo(retrieveFollowersBufferBlock, new DataflowLinkOptions { PropagateCompletion = true }); + retrieveFollowersBufferBlock.LinkTo(sendTweetsToFollowersBlock, new DataflowLinkOptions { PropagateCompletion = true }); // Launch twitter user retriever var retrieveTwitterAccountsTask = _retrieveTwitterAccountsProcessor.GetTwitterUsersAsync(twitterUsersBufferBlock, ct); // Wait - await Task.WhenAll(retrieveTwitterAccountsTask, sendTweetsToFollowersBlock.Completion); + await Task.WhenAny(new []{ retrieveTwitterAccountsTask , sendTweetsToFollowersBlock.Completion}); var foreground = Console.ForegroundColor; Console.ForegroundColor = ConsoleColor.Red;