Hi Daniel, We use flinkCompatibilityMatrix [1] to check the Flink compatibility with python. This is python equivalent to validatesRunner tests in java for portable runners. I think we can reuse it for Samza Portable runner with minor refactoring.
[1] https://github.com/apache/beam/blob/bdb1a713a120a887e71e85c77879dc4446a58541/sdks/python/build.gradle#L305 On Mon, Apr 22, 2019 at 3:21 PM Daniel Chen <[email protected]> wrote: > Hi everyone, > > I'm working on improving the validation of the Python portable Samza > runner. For java, we have the gradle task ( :validatesRunner) that runs the > runner validation tests. > I am looking for pointers on how to similarly integrate/enable the > portability and Python tests for the Samza runner. > > Any help will be greatly appreciated. > > Thanks, > Daniel >
