Skip to content

Commit 27af330

Browse files
authored
Merge pull request #642 from splunk/dev/MP/re-enable-test_delete
Re-enable test_delete from test_input.py
2 parents c7e9f87 + 731bffd commit 27af330

File tree

1 file changed

+28
-20
lines changed

1 file changed

+28
-20
lines changed

tests/integration/test_input.py

Lines changed: 28 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -282,27 +282,35 @@ def test_update(self):
282282
entity.refresh()
283283
self.assertEqual(entity.host, kwargs["host"])
284284

285-
@pytest.mark.skip("flaky")
286285
def test_delete(self):
287-
inputs = self.service.inputs
288-
remaining = len(self._test_entities) - 1
289-
for input_entity in self._test_entities.values():
290-
name = input_entity.name
291-
kind = input_entity.kind
292-
self.assertTrue(name in inputs)
293-
self.assertTrue((name, kind) in inputs)
294-
if remaining == 0:
295-
inputs.delete(name)
296-
self.assertFalse(name in inputs)
297-
else:
298-
if not name.startswith("boris"):
299-
self.assertRaises(
300-
client.AmbiguousReferenceException, inputs.delete, name
301-
)
302-
self.service.inputs.delete(name, kind)
303-
self.assertFalse((name, kind) in inputs)
304-
self.assertRaises(client.HTTPError, input_entity.refresh)
305-
remaining -= 1
286+
udpName, udpKind = (
287+
self._test_entities["udp"].name,
288+
self._test_entities["udp"].kind,
289+
)
290+
tcpName, tcpKind = (
291+
self._test_entities["tcp"].name,
292+
self._test_entities["tcp"].kind,
293+
)
294+
295+
# Delete via the Input entity itself.
296+
self._test_entities["tcp"].delete()
297+
298+
# Delete via the Inputs collection.
299+
self.service.inputs.delete(udpName, udpKind)
300+
301+
for input in self.service.inputs:
302+
if input.name == tcpName and input.kind == tcpKind:
303+
self.fail(f"{tcpName} {tcpKind} still exists")
304+
if input.name == udpName and input.kind == udpKind:
305+
self.fail(f"{udpName} {udpKind} still exists")
306+
307+
def test_delete_ambiguous_reference(self):
308+
# _test_entities["udp"] and _test_entities["tcp"] share the same input name, thus
309+
# deletion only with the name, without specifying the input kind, should fail.
310+
name = self._test_entities["udp"].name
311+
self.assertRaises(
312+
client.AmbiguousReferenceException, lambda: self.service.inputs.delete(name)
313+
)
306314

307315

308316
if __name__ == "__main__":

0 commit comments

Comments
 (0)