[Transform] fixes tests which might fail due to auto-stop (#47867)
Batch transforms automatically stop after all data has processed, therefore tests can not reliable test the state. This change rewrites tests to remove the unreliable tests or use continuous transforms instead as they do not auto-stop. fixes #47441
This commit is contained in:
parent
d210bfa888
commit
fd1c4c198a
|
@ -28,6 +28,24 @@ setup:
|
|||
"aggs": {"avg_response": {"avg": {"field": "responsetime"}}}
|
||||
}
|
||||
}
|
||||
- do:
|
||||
transform.put_transform:
|
||||
transform_id: "airline-transform-start-stop-continuous"
|
||||
body: >
|
||||
{
|
||||
"source": { "index": "airline-data" },
|
||||
"dest": { "index": "airline-data-by-airline-start-stop-cont" },
|
||||
"pivot": {
|
||||
"group_by": { "airline": {"terms": {"field": "airline"}}},
|
||||
"aggs": {"avg_response": {"avg": {"field": "responsetime"}}}
|
||||
},
|
||||
"sync": {
|
||||
"time": {
|
||||
"field": "time",
|
||||
"delay": "90m"
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
---
|
||||
teardown:
|
||||
|
@ -39,7 +57,14 @@ teardown:
|
|||
- do:
|
||||
transform.delete_transform:
|
||||
transform_id: "airline-transform-start-stop"
|
||||
|
||||
- do:
|
||||
transform.stop_transform:
|
||||
transform_id: "airline-transform-start-stop-continuous"
|
||||
timeout: "10m"
|
||||
wait_for_completion: true
|
||||
- do:
|
||||
transform.delete_transform:
|
||||
transform_id: "airline-transform-start-stop-continuous"
|
||||
---
|
||||
"Test start transform":
|
||||
- do:
|
||||
|
@ -103,7 +128,6 @@ teardown:
|
|||
transform_id: "airline-transform-start-stop"
|
||||
- match: { count: 1 }
|
||||
- match: { transforms.0.id: "airline-transform-start-stop" }
|
||||
- match: { transforms.0.state: "/started|indexing/" }
|
||||
|
||||
- do:
|
||||
transform.stop_transform:
|
||||
|
@ -128,28 +152,8 @@ teardown:
|
|||
transform_id: "airline-transform-start-stop"
|
||||
- match: { count: 1 }
|
||||
- match: { transforms.0.id: "airline-transform-start-stop" }
|
||||
- match: { transforms.0.state: "/started|indexing/" }
|
||||
---
|
||||
"Test start/stop/start continuous transform":
|
||||
- do:
|
||||
transform.put_transform:
|
||||
transform_id: "airline-transform-start-stop-continuous"
|
||||
body: >
|
||||
{
|
||||
"source": { "index": "airline-data" },
|
||||
"dest": { "index": "airline-data-by-airline-start-stop-cont" },
|
||||
"pivot": {
|
||||
"group_by": { "airline": {"terms": {"field": "airline"}}},
|
||||
"aggs": {"avg_response": {"avg": {"field": "responsetime"}}}
|
||||
},
|
||||
"sync": {
|
||||
"time": {
|
||||
"field": "time",
|
||||
"delay": "90m"
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
- do:
|
||||
transform.start_transform:
|
||||
transform_id: "airline-transform-start-stop-continuous"
|
||||
|
@ -192,10 +196,6 @@ teardown:
|
|||
transform_id: "airline-transform-start-stop-continuous"
|
||||
wait_for_completion: true
|
||||
- match: { acknowledged: true }
|
||||
|
||||
- do:
|
||||
transform.delete_transform:
|
||||
transform_id: "airline-transform-start-stop-continuous"
|
||||
---
|
||||
"Test stop missing transform":
|
||||
- do:
|
||||
|
@ -235,18 +235,24 @@ teardown:
|
|||
"pivot": {
|
||||
"group_by": { "airline": {"terms": {"field": "airline"}}},
|
||||
"aggs": {"avg_response": {"avg": {"field": "responsetime"}}}
|
||||
},
|
||||
"sync": {
|
||||
"time": {
|
||||
"field": "time",
|
||||
"delay": "90m"
|
||||
}
|
||||
}
|
||||
}
|
||||
- do:
|
||||
transform.start_transform:
|
||||
transform_id: "airline-transform-start-stop"
|
||||
transform_id: "airline-transform-start-stop-continuous"
|
||||
- match: { acknowledged: true }
|
||||
|
||||
- do:
|
||||
transform.get_transform_stats:
|
||||
transform_id: "airline-transform-start-stop"
|
||||
transform_id: "airline-transform-start-stop-continuous"
|
||||
- match: { count: 1 }
|
||||
- match: { transforms.0.id: "airline-transform-start-stop" }
|
||||
- match: { transforms.0.id: "airline-transform-start-stop-continuous" }
|
||||
- match: { transforms.0.state: "/started|indexing/" }
|
||||
|
||||
- do:
|
||||
|
@ -263,7 +269,7 @@ teardown:
|
|||
|
||||
- do:
|
||||
transform.stop_transform:
|
||||
transform_id: "airline-transform-start-stop"
|
||||
transform_id: "airline-transform-start-stop-continuous"
|
||||
wait_for_completion: true
|
||||
- match: { acknowledged: true }
|
||||
|
||||
|
@ -306,7 +312,7 @@ teardown:
|
|||
|
||||
- do:
|
||||
transform.start_transform:
|
||||
transform_id: "airline-transform-start-stop"
|
||||
transform_id: "airline-transform-start-stop-continuous"
|
||||
- match: { acknowledged: true }
|
||||
|
||||
- do:
|
||||
|
@ -318,7 +324,7 @@ teardown:
|
|||
- do:
|
||||
transform.get_transform_stats:
|
||||
transform_id: "*"
|
||||
- match: { count: 2 }
|
||||
- match: { count: 3 }
|
||||
- match: { transforms.0.state: "stopped" }
|
||||
- match: { transforms.1.state: "stopped" }
|
||||
|
||||
|
|
Loading…
Reference in New Issue