[ https://issues.apache.org/jira/browse/BEAM-2988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ahmet Altay reassigned BEAM-2988: --------------------------------- Assignee: Charles Chen (was: Ahmet Altay) > PubSub subscriptions automatically created in Python DirectRunner not > reliably cleaned up > ----------------------------------------------------------------------------------------- > > Key: BEAM-2988 > URL: https://issues.apache.org/jira/browse/BEAM-2988 > Project: Beam > Issue Type: Bug > Components: sdk-py-core > Reporter: Charles Chen > Assignee: Charles Chen > Priority: Minor > > In the Python DirectRunner, we attempt to garbage-collect > automatically-created PubSub subscriptions here > (https://github.com/apache/beam/blob/446f311746b74bdfb420ba71d76097d683fde9a1/sdks/python/apache_beam/runners/direct/transform_evaluator.py#L370). > However, this mechanism may not succeed, since it is called on the __del__ > method when other references may have already been garbage-collected. We > should further investigate the mechanism here and attempt to make it more > reliable. -- This message was sent by Atlassian JIRA (v6.4.14#64029)