Open pavelhoral opened 5 months ago
This is awesome. Thanks for debugging and adding a regression test! I think we can actually leverage the open
function in streamx for this.
This is awesome. Thanks for debugging and adding a regression test! I think we can actually leverage the
open
function in streamx for this.
Not sure why, but moving the code to open
function breaks the pipeline completely. Seems like open
state is too soon for data being produced by the stream.
UPDATE: I am dumb... forgot about the callback.
Pushed new changes (switch to open
method).
Any update on this? Is there anything else I can do? Ty.
Any update on this? Is there anything else I can do? Ty.
Would love to have this merged and released. If there is anything I can do to help that, let me know.
This PR fixes premature start of the glob stream which can lead to closing the resulting Transform stream before it is being properly processed by upstream components. This can lead to very strange race conditions and unfinished pipelines.