I put these here because it runs them in various modes (directly, over Grpc with and without multiple threads, over subprocesses). I view the ones in userstate_test as more user-api-facing ones (though note that those can't be used here, as they use the streaming test stream and avoid assert_that due to it being broken in streaming mode on the other direct runner, and instead have a DoFn that stores things into a list (which of course won't work cross-process).
So, yes, it'd be nice to unify, but not right now. (What I'd like to do eventually is expand this suite of tests into a basic Runner Compatibility Matrix test...) [ Full content available at: https://github.com/apache/beam/pull/6349 ] This message was relayed via gitbox.apache.org for [email protected]
