Skip to content

Commit f44c371

Browse files
committed
foreach put pipeline processors is no longer an array as per elastic/elasticsearch#19402
1 parent ec88d25 commit f44c371

File tree

2 files changed

+12
-18
lines changed

2 files changed

+12
-18
lines changed

src/Nest/Ingest/Processors/ForeachProcessor.cs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -15,15 +15,15 @@ public interface IForeachProcessor : IProcessor
1515
[JsonProperty("field")]
1616
Field Field { get; set; }
1717

18-
[JsonProperty("processors")]
19-
IEnumerable<IProcessor> Processors { get; set; }
18+
[JsonProperty("processor")]
19+
IProcessor Processor { get; set; }
2020
}
2121

2222
public class ForeachProcessor : ProcessorBase, IForeachProcessor
2323
{
2424
protected override string Name => "foreach";
2525
public Field Field { get; set; }
26-
public IEnumerable<IProcessor> Processors { get; set; }
26+
public IProcessor Processor { get; set; }
2727
}
2828

2929
public class ForeachProcessorDescriptor<T>
@@ -34,14 +34,14 @@ public class ForeachProcessorDescriptor<T>
3434

3535
Field IForeachProcessor.Field { get; set; }
3636

37-
IEnumerable<IProcessor> IForeachProcessor.Processors { get; set; }
37+
IProcessor IForeachProcessor.Processor { get; set; }
3838

3939
public ForeachProcessorDescriptor<T> Field(Field field) => Assign(a => a.Field = field);
4040

4141
public ForeachProcessorDescriptor<T> Field(Expression<Func<T, object>> objectPath) =>
4242
Assign(a => a.Field = objectPath);
4343

44-
public ForeachProcessorDescriptor<T> Processors(Func<ProcessorsDescriptor, IPromise<IList<IProcessor>>> selector) =>
45-
Assign(a => a.Processors = selector?.Invoke(new ProcessorsDescriptor())?.Value);
44+
public ForeachProcessorDescriptor<T> Processor(Func<ProcessorsDescriptor, IPromise<IList<IProcessor>>> selector) =>
45+
Assign(a => a.Processor = selector?.Invoke(new ProcessorsDescriptor())?.Value?.FirstOrDefault());
4646
}
4747
}

src/Tests/Ingest/PutPipeline/PutPipelineApiTests.cs

Lines changed: 6 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -73,14 +73,11 @@ protected override LazyResponses ClientUsage() => Calls(
7373
@foreach = new
7474
{
7575
field = "tags",
76-
processors = new object[]
76+
processors = new
7777
{
78-
new
78+
uppercase = new
7979
{
80-
uppercase = new
81-
{
82-
field = "_value.name"
83-
}
80+
field = "_value.name"
8481
}
8582
}
8683
}
@@ -195,7 +192,7 @@ protected override LazyResponses ClientUsage() => Calls(
195192
)
196193
.Foreach<Project>(fe => fe
197194
.Field(p => p.Tags)
198-
.Processors(pps => pps
195+
.Processor(pps => pps
199196
.Uppercase<Tag>(uc => uc
200197
.Field("_value.name")
201198
)
@@ -274,12 +271,9 @@ protected override LazyResponses ClientUsage() => Calls(
274271
new ForeachProcessor
275272
{
276273
Field = Infer.Field<Project>(p => p.Tags),
277-
Processors = new IProcessor[]
274+
Processor = new UppercaseProcessor
278275
{
279-
new UppercaseProcessor
280-
{
281-
Field = "_value.name"
282-
}
276+
Field = "_value.name"
283277
}
284278
},
285279
new GrokProcessor

0 commit comments

Comments
 (0)