tvalentyn
tvalentyn
I don't think there has been significant work on Python streaming direct runner recently.
Let me know when this is ready to review/merge.
Run Python 3.9 PostCommit
Noting that tests passed.
I was able to bisect grpc commits to debug another issue, while building grpc from sources, in case it helps, my notes are in https://github.com/apache/beam/issues/22533#issuecomment-1200062320
I think mocking the value in tests is fine if it does not result in additional flakiness. What happens if the server is shut down prematurely - will it restart...
Or is the issue that the test is waiting to shutdown the servers after completing execution of the scenario?
Do you set `--save_main_session` pipeline option on your pipeline? If not could you try that please? Unless you are explicitly doing alpha-testing of FnApi execution mode on Dataflow, you should...
> @tvalentyn Can you enable the gh workflow? I clicked the button to approve the run, lmk if other action is necessary.
cc: @ryanthompson591 for initial pass.