from rift.tasklets.rwimagemgr import upload
from rift.package import checksums
from rift.test.dts import async_test
from rift.tasklets.rwimagemgr import upload
from rift.package import checksums
from rift.test.dts import async_test
task_pb_msg = upload_task.pb_msg
self.assertEqual(upload_task.image_name, task_pb_msg.image_name)
task_pb_msg = upload_task.pb_msg
self.assertEqual(upload_task.image_name, task_pb_msg.image_name)
@async_test
def test_create_image_name_and_checksum_exists(self):
with self.create_upload_task(self.account) as upload_task:
@async_test
def test_create_image_name_and_checksum_exists(self):
with self.create_upload_task(self.account) as upload_task:
id="asdf",
name=upload_task.image_name,
checksum=upload_task.image_checksum
id="asdf",
name=upload_task.image_name,
checksum=upload_task.image_checksum
def __init__(self, *args, **kwargs):
self._loop = asyncio.get_event_loop()
self._log = logging.getLogger(__file__)
def __init__(self, *args, **kwargs):
self._loop = asyncio.get_event_loop()
self._log = logging.getLogger(__file__)
ImageMockMixin.__init__(self, self._log)
unittest.TestCase.__init__(self, *args, **kwargs)
@async_test
def test_controller_single_task_job(self):
ImageMockMixin.__init__(self, self._log)
unittest.TestCase.__init__(self, *args, **kwargs)
@async_test
def test_controller_single_task_job(self):
with self.create_upload_task(self.account) as upload_task:
job_id = controller.create_job([upload_task])
with self.create_upload_task(self.account) as upload_task:
job_id = controller.create_job([upload_task])
with self.create_upload_task(self.account) as upload_task1:
with self.create_upload_task(self.account) as upload_task2:
with self.create_upload_task(self.account) as upload_task1:
with self.create_upload_task(self.account) as upload_task2:
with self.create_upload_task(self.account) as upload_task1:
with self.create_upload_task(self.account) as upload_task2:
with self.create_upload_task(self.account) as upload_task1:
with self.create_upload_task(self.account) as upload_task2: