(keys: List[str], collection: AsyncCollection)
| 111 | |
| 112 | |
| 113 | async def remove_docs(keys: List[str], collection: AsyncCollection) -> None: |
| 114 | for key in keys: |
| 115 | try: |
| 116 | await collection.remove(key) |
| 117 | except DocumentNotFoundException: |
| 118 | pass |
| 119 | |
| 120 | |
| 121 | async def setup(cluster: AsyncCluster, collection: AsyncCollection) -> List[str]: |