/ - Diff - ganeti-local - Greek Research and Technology Network's projects

Revision 075a29be

           })
     def _ParseMigrateInstanceRequest(name, data):
       """Parses a request for an instance migration.
       @rtype: L{opcodes.OpInstanceMigrate}
       @return: Instance migration opcode
       """
       return baserlib.FillOpcode(opcodes.OpInstanceMigrate, data, {
         "instance_name": name,
         })
     class R_2_instances_name_migrate(baserlib.ResourceBase):
     class R_2_instances_name_migrate(baserlib.OpcodeResource):
       """/2/instances/[instance_name]/migrate resource.
       """
       def PUT(self):
         """Migrates an instance.
       PUT_OPCODE = opcodes.OpInstanceMigrate
         @return: a job id
       def GetPutOpInput(self):
         """Migrates an instance.
         """
         baserlib.CheckType(self.request_body, dict, "Body contents")
         op = _ParseMigrateInstanceRequest(self.items[0], self.request_body)
         return self.SubmitJob([op])
         return (self.request_body, {
           "instance_name": self.items[0],
           })
     class R_2_instances_name_failover(baserlib.ResourceBase):

           self.assertRaises(http.HttpBadRequest, handler.PUT)
     class TestParseMigrateInstanceRequest(testutils.GanetiTestCase):
       def setUp(self):
         testutils.GanetiTestCase.setUp(self)
         self.Parse = rlib2._ParseMigrateInstanceRequest
     class TestInstanceMigrate(testutils.GanetiTestCase):
       def test(self):
         clfactory = _FakeClientFactory(_FakeClient)
         name = "instYooho6ek"
         for cleanup in [False, True]:
-...
               "cleanup": cleanup,
               "mode": mode,
+              }
             op = self.Parse(name, data)
             self.assert_(isinstance(op, opcodes.OpInstanceMigrate))
             handler = _CreateHandler(rlib2.R_2_instances_name_migrate, [name], {},
                                      data, clfactory)
             job_id = handler.PUT()
             cl = clfactory.GetNextClient()
             self.assertRaises(IndexError, clfactory.GetNextClient)
             (exp_job_id, (op, )) = cl.GetNextSubmittedJob()
             self.assertEqual(job_id, exp_job_id)
             self.assertTrue(isinstance(op, opcodes.OpInstanceMigrate))
             self.assertEqual(op.instance_name, name)
             self.assertEqual(op.mode, mode)
             self.assertEqual(op.cleanup, cleanup)
             self.assertFalse(hasattr(op, "dry_run"))
             self.assertFalse(hasattr(op, "force"))
             self.assertRaises(IndexError, cl.GetNextSubmittedJob)
       def testDefaults(self):
         clfactory = _FakeClientFactory(_FakeClient)
         name = "instnohZeex0"
         op = self.Parse(name, {})
         self.assert_(isinstance(op, opcodes.OpInstanceMigrate))
         handler = _CreateHandler(rlib2.R_2_instances_name_migrate, [name], {}, {},
                                  clfactory)
         job_id = handler.PUT()
         cl = clfactory.GetNextClient()
         self.assertRaises(IndexError, clfactory.GetNextClient)
         (exp_job_id, (op, )) = cl.GetNextSubmittedJob()
         self.assertEqual(job_id, exp_job_id)
         self.assertTrue(isinstance(op, opcodes.OpInstanceMigrate))
         self.assertEqual(op.instance_name, name)
         self.assertFalse(hasattr(op, "mode"))
         self.assertFalse(hasattr(op, "cleanup"))
         self.assertFalse(hasattr(op, "dry_run"))
         self.assertFalse(hasattr(op, "force"))
         self.assertRaises(IndexError, cl.GetNextSubmittedJob)
     class TestParseRenameInstanceRequest(testutils.GanetiTestCase):

Also available in: Unified diff

Synnefo » snf-ganeti » ganeti-local

Revision 075a29be