AMOOOMA commented on code in PR #37112:
URL: https://github.com/apache/beam/pull/37112#discussion_r2744011272
##########
sdks/python/apache_beam/utils/multi_process_shared.py:
##########
@@ -79,6 +83,10 @@ def singletonProxy_release(self):
assert self._SingletonProxy_valid
self._SingletonProxy_valid = False
+ def singletonProxy_unsafe_hard_delete(self):
+ assert self._SingletonProxy_valid
+ self._SingletonProxy_entry.unsafe_hard_delete()
Review Comment:
Yep technically we won't need this now since we are recreating the MPS
object everytime. But probably good to have in case in the future we want some
more flexibility.
--
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]
