Mute ResidentTaskIntegrationTest.
ClosedAll Users
Actions

Show First 20 Lines • Show All 100 Lines • ▼ Show 20 Line(s)
101	101	update.code shouldBe 200
102	102	// we do not wait for the deployment to finish here to get the task events
103	103
104	104	waitForStatusUpdates(StatusUpdate.TASK_RUNNING)
105	105	waitForDeployment(update)
106	106	waitForStatusUpdates(StatusUpdate.TASK_FINISHED)
107	107	}
108	108
109		test("resident task is launched completely on reserved resources") { f =>
	109	test("resident task is launched completely on reserved resources", Unstable) { f =>
110	110	Given("A resident app")
111	111	val app = f.residentApp(portDefinitions = Seq.empty /* prevent problems by randomized port assignment */ )
112	112
113	113	When("A task is launched")
114	114	f.createSuccessfully(app)
115	115
116	116	Then("used and reserved resources correspond to the app")
117	117	val state: RestResult[ITMesosState] = mesos.state
Show All 29 Lines
147	147
148	148	When("We scale up to 5 instances")
149	149	f.scaleToSuccessfully(app.id, 5)
150	150
151	151	Then("exactly 5 tasks have been created")
152	152	f.launchedTasks(app.id).size shouldBe 5
153	153	}
154	154
155		test("Scale Down") { f =>
	155	test("Scale Down", Unstable) { f =>
156	156	Given("a resident app with 5 instances")
157	157	val app = f.createSuccessfully(f.residentApp(instances = 5))
158	158
159	159	When("we scale down to 0 instances")
160	160	f.suspendSuccessfully(app.id)
161	161
162	162	Then("all tasks are suspended")
163	163	val all = f.allTasks(app.id)
164	164	all.size shouldBe 5
165	165	all.count(_.launched) shouldBe 0
166	166	all.count(_.suspended) shouldBe 5
167	167	}
168	168
169		test("Restart") { f =>
	169	test("Restart", Unstable) { f =>
170	170	Given("a resident app with 5 instances")
171	171	val app = f.createSuccessfully(
172	172	f.residentApp(
173	173	instances = 5,
174	174	// FIXME: we need to retry starting tasks since there is a race-condition in Mesos,
175	175	// probably related to our recycling of the task ID (but unconfirmed)
176	176	backoffDuration = 300.milliseconds
177	177	)
▲ Show 20 Lines • Show All 200 Lines • Show Last 20 Lines

Mute ResidentTaskIntegrationTest.ClosedAll UsersActions

Details

Diff Detail

Revision Contents

Diff 1087

src/test/scala/mesosphere/marathon/integration/ResidentTaskIntegrationTest.scala

Mute ResidentTaskIntegrationTest.
ClosedAll Users
Actions