This is an automated email from the ASF dual-hosted git repository.
pabloem pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new e818a0c4ad5 Feat: implementing active cleanup of orphaned
subscriptions for the `taxirides` topic. (#39728)
e818a0c4ad5 is described below
commit e818a0c4ad53d13bbe22e63fd8890cd00363286a
Author: HansMarcus01 <[email protected]>
AuthorDate: Fri Aug 14 12:06:37 2026 -0600
Feat: implementing active cleanup of orphaned subscriptions for the
`taxirides` topic. (#39728)
---
.test-infra/tools/stale_cleaner.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/.test-infra/tools/stale_cleaner.py
b/.test-infra/tools/stale_cleaner.py
index a00bb3ad7ab..3c8b21c806d 100644
--- a/.test-infra/tools/stale_cleaner.py
+++ b/.test-infra/tools/stale_cleaner.py
@@ -432,7 +432,7 @@ def clean_pubsub_subscriptions():
cleaner.refresh()
# Delete stale resources
- cleaner.delete_stale(dry_run=True) # Keep dry_run=True to avoid accidental
deletions during testing
+ cleaner.delete_stale(dry_run=False)
if __name__ == "__main__":
# Clean up stale PubSub topics
