Remove the specified entries from the queue. Arguments: revs: Stash revisions or queued exp names to be removed. Returns: Revisions (or names) which were removed.
(self: "LocalCeleryQueue", revs: Collection[str])
| 110 | |
| 111 | |
| 112 | def celery_remove(self: "LocalCeleryQueue", revs: Collection[str]) -> list[str]: |
| 113 | """Remove the specified entries from the queue. |
| 114 | |
| 115 | Arguments: |
| 116 | revs: Stash revisions or queued exp names to be removed. |
| 117 | |
| 118 | Returns: |
| 119 | Revisions (or names) which were removed. |
| 120 | """ |
| 121 | |
| 122 | match_results = self.match_queue_entry_by_name( |
| 123 | revs, self.iter_queued(), self.iter_done() |
| 124 | ) |
| 125 | |
| 126 | remained: list[str] = [] |
| 127 | removed: list[str] = [] |
| 128 | entry_to_remove: list[QueueEntry] = [] |
| 129 | for name, entry in match_results.items(): |
| 130 | if entry: |
| 131 | entry_to_remove.append(entry) |
| 132 | removed.append(name) |
| 133 | else: |
| 134 | remained.append(name) |
| 135 | |
| 136 | if remained: |
| 137 | raise UnresolvedExpNamesError(remained) |
| 138 | |
| 139 | if entry_to_remove: |
| 140 | remove_tasks(self, entry_to_remove) |
| 141 | |
| 142 | return removed |
no test coverage detected