-
Notifications
You must be signed in to change notification settings - Fork 157
Description
I'm experimenting with the library, and trying to make something like a really simple ETL. The problem is that for this particular case reactivity does not work for me, since I need to guarantee that the flow is executed only once (and has no loops, solved with the toolkit).
For example, if I have a node in charge of making insertions in a database table. Every time I modify previous nodes it makes undesired insertions. As the processes can be time-consuming, I would also need some kind of node states (Undefined, Waiting, Queued, Executed, Error).
Is it even possible to somehow synchronize the nodes? I have managed to get close to something operational by using Subjects in the outputs and an execution method. But for some reason the outputs are not propagated in time to the inputs.