Skip to content

Commit d5eea11

Browse files
authored
Quick fix on deleting pubsub resources (#35513)
1 parent d1fce60 commit d5eea11

1 file changed

Lines changed: 2 additions & 3 deletions

File tree

.test-infra/tools/stale_cleaner.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -301,9 +301,8 @@ def _active_resources(self) -> dict:
301301
return d
302302

303303
def _delete_resource(self, resource_name: str) -> None:
304-
topic_name = resource_name.split('/')[-1]
305-
print(f"{self.clock()} - Deleting PubSub topic {topic_name}")
306-
self.client.delete_topic(name=resource_name)
304+
print(f"{self.clock()} - Deleting PubSub topic {resource_name}")
305+
self.client.delete_topic(request={"topic": resource_name})
307306

308307
if __name__ == "__main__":
309308
project_id = DEFAULT_PROJECT_ID

0 commit comments

Comments
 (0)