diff --git a/.github/workflows/test.yml b/.github/workflows/test.yml index 8b3fca0..063bda7 100644 --- a/.github/workflows/test.yml +++ b/.github/workflows/test.yml @@ -17,7 +17,7 @@ jobs: runs-on: ubuntu-latest strategy: matrix: - minor: [7, 8, 9, 11] + minor: [8, 9, 10, 11] steps: - uses: actions/checkout@v2 - uses: actions/setup-python@v1 diff --git a/karton/system/system.py b/karton/system/system.py index 3fb78cb..420243a 100644 --- a/karton/system/system.py +++ b/karton/system/system.py @@ -75,20 +75,20 @@ def gc_collect_tasks(self) -> None: current_time = time.time() to_delete = [] - queues_to_remove = set() + queues_to_clear = set() online_consumers = self.backend.get_online_consumers() for bind in self.backend.get_binds(): identity = bind.identity if identity not in online_consumers and not bind.persistent: # If offline and not persistent: mark queue to be removed - queues_to_remove.add(identity) + queues_to_clear.add(identity) self.log.info("Non-persistent: removing bind %s", identity) self.backend.unregister_bind(identity) self.backend.delete_consumer_queues(identity) for task in self.backend.iter_all_tasks(parse_resources=False): root_tasks.add(task.root_uid) - if task.headers.get("receiver") in queues_to_remove: + if task.headers.get("receiver") in queues_to_clear: to_delete.append(task) self.log.info( "Task %s is abandoned by inactive non-persistent consumer."