Skip to content

Dataflow waiting for todo items on Exception. #25

Description

@marlonbidu

Hi,

I'm trying to make a Dataflow return a Exception state when a exception occurs on the middle of processing, but the Dataflow remains to waiting for todo items to complete from what i can see.
The message that log returns in loop is [Gridsum.DataflowEx.PerfMon].[Debug] [MyFlow1] has 19 todo items (in:0, out:19) at this moment.
How can i stop all the pipeline when i receive a unhandled exception at a point of my flow?

Edit: the this.Complete() call inside SignalAndWaitForCompletionAsync make this waiting behavior.
If i substitute SignalAndWaitForCompletionAsync with flow.CompletionTask.Wait(), the exception is returned to my application.
In my model, i need that the application handle the exception.

Thanks.

Activity

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

      Milestone

      No milestone

      Relationships

      None yet

      Development

      No branches or pull requests

      Issue actions