(db, database, pipeline)
| 31 | db[database].insert_many(document) |
| 32 | |
| 33 | def aggregate(db, database, pipeline): |
| 34 | result = [] |
| 35 | for x in db[database].aggregate(pipeline): |
| 36 | result.append(x) |
| 37 | return result |
| 38 | |
| 39 | def find_one(db, database, kwargs): |
| 40 | x = db[database].find_one(**kwargs) |
nothing calls this directly
no outgoing calls
no test coverage detected