""" This class starts and manages ImageUploadJobs """
MAX_COMPLETED_JOBS = 20
- def __init__(self, log, loop, max_completed_jobs=MAX_COMPLETED_JOBS):
+ def __init__(self, log, loop, project, max_completed_jobs=MAX_COMPLETED_JOBS):
self._log = log
self._loop = loop
+ self._project = project
self._job_id_gen = itertools.count(1)
self._max_completed_jobs = max_completed_jobs
if failed_tasks:
self._log.error("%s had %s FAILED tasks.", self, len(failed_tasks))
+ for ftask in failed_tasks:
+ self._log.error("%s : Failed to upload image : %s to cloud_account : %s", self, ftask.image_name, ftask.cloud_account)
self.state = "FAILED"
else:
self._log.debug("%s tasks completed successfully", len(self._upload_tasks))