(self, task)
| 543 | |
| 544 | # Mark a task done |
| 545 | def doneTask(self, task): |
| 546 | task["done"] = True |
| 547 | self.tasks.remove(task) # Remove from queue |
| 548 | if task["optional_hash_id"]: |
| 549 | self.log.debug( |
| 550 | "Downloaded optional file in %.3fs, adding to hashfield: %s" % |
| 551 | (time.time() - task["time_started"], task["inner_path"]) |
| 552 | ) |
| 553 | self.site.content_manager.optionalDownloaded(task["inner_path"], task["optional_hash_id"], task["size"]) |
| 554 | self.site.onFileDone(task["inner_path"]) |
| 555 | task["evt"].set(True) |
| 556 | if not self.tasks: |
| 557 | gevent.spawn(self.checkComplete) |
| 558 | |
| 559 | # Mark a task failed |
| 560 | def failTask(self, task): |
no test coverage detected