(self, collection)
| 117 | self.log.debug('There are %s jobs in the scheduler' % len(self.ram['schedules'])) |
| 118 | |
| 119 | async def apply(self, collection): |
| 120 | if collection not in self.ram: |
| 121 | self.ram[collection] = [] |
| 122 | |
| 123 | async def load_data(self, plugins=()): |
| 124 | loop = asyncio.get_event_loop() |
no outgoing calls