--- "Test ack watch api": - do: cluster.health: wait_for_status: green - do: watcher.put_watch: id: "my_watch" body: > { "trigger": { "schedule": { "hourly": { "minute": [ 0, 5 ] } } }, "input": { "simple": { "payload": { "send": "yes" } } }, "condition": { "always": {} }, "actions": [ { "test_index": { "index": { "index": "test", "doc_type": "test2" } } } ] } - match: { _id: "my_watch" } - do: cluster.health: wait_for_status: green - do: watcher.ack_watch: id: "my_watch" - match: { "status.ack.state" : "awaits_execution" } - do: watcher.delete_watch: id: "my_watch" - match: { found: true }