tvalentyn opened a new pull request, #26777: URL: https://github.com/apache/beam/pull/26777
If user code raises a BaseException during processing, bundle will be marked as failed by the SDK but will not be reported as failed to the worker harness. To fix this, match the error handling catch clause in the outer method to the error handling close where bundle is marked failed: https://github.com/apache/beam/blob/dbefe4f8b0915d4d1bd83f315705efaf0b526d3d/sdks/python/apache_beam/runners/worker/sdk_worker.py#L683 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
