Skip to content

Commit a3abf2e

Browse files
committed
add test feature
1 parent e204957 commit a3abf2e

File tree

3 files changed

+16
-0
lines changed
  • modules/ingest-common/src/yamlRestTest/resources/rest-api-spec/test/ingest
  • rest-api-spec/src/yamlRestTest/resources/rest-api-spec/test/simulate.ingest
  • server/src/main/java/org/elasticsearch/ingest

3 files changed

+16
-0
lines changed

modules/ingest-common/src/yamlRestTest/resources/rest-api-spec/test/ingest/120_grok.yml

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -158,6 +158,9 @@ teardown:
158158
159159
---
160160
"Test simulate with invalid GROK pattern":
161+
- requires:
162+
cluster_features: [ "simulate.ingest.400_on_failure" ]
163+
reason: "simulate.ingest returned 500 on failure before"
161164
- skip:
162165
features: headers
163166
- do:

rest-api-spec/src/yamlRestTest/resources/rest-api-spec/test/simulate.ingest/10_basic.yml

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -600,6 +600,9 @@ setup:
600600

601601
---
602602
"Test bad pipeline substitution":
603+
- requires:
604+
cluster_features: [ "simulate.ingest.400_on_failure" ]
605+
reason: "simulate.ingest returned 500 on failure before"
603606
- skip:
604607
features: [headers, allowed_warnings]
605608

@@ -751,6 +754,9 @@ setup:
751754

752755
---
753756
"Test simulate with pipeline with created_date":
757+
- requires:
758+
cluster_features: [ "simulate.ingest.400_on_failure" ]
759+
reason: "simulate.ingest returned 500 on failure before"
754760
- requires:
755761
test_runner_features: capabilities
756762
capabilities:

server/src/main/java/org/elasticsearch/ingest/IngestFeatures.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,8 @@
1616
import java.util.Set;
1717

1818
public class IngestFeatures implements FeatureSpecification {
19+
private static final NodeFeature SIMULATE_INGEST_400_ON_FAILURE = new NodeFeature("simulate.ingest.400_on_failure", true);
20+
1921
@Override
2022
public Set<NodeFeature> getFeatures() {
2123
if (DataStream.LOGS_STREAM_FEATURE_FLAG) {
@@ -24,4 +26,9 @@ public Set<NodeFeature> getFeatures() {
2426
return Set.of();
2527
}
2628
}
29+
30+
@Override
31+
public Set<NodeFeature> getTestFeatures() {
32+
return Set.of(SIMULATE_INGEST_400_ON_FAILURE);
33+
}
2734
}

0 commit comments

Comments
 (0)