Add proper example to sequence docs

Author: Jeffail

lib/input/csv.go

@@ -114,9 +114,13 @@ func NewCSVFile(conf Config, mgr types.Manager, log log.Modular, stats metrics.T
 			}
 
 			path := pathsRemaining[0]
+			handle, err := os.Open(path)
+			if err != nil {
+				return nil, err
+			}
 			pathsRemaining = pathsRemaining[1:]
 
-			return os.Open(path)
+			return handle, nil
 		},
 		func(context.Context) {},
 		optCSVSetComma(comma),

lib/input/sequence.go

@@ -30,22 +30,22 @@ must not be consumed in parallel.`,
 		Footnotes: `
 ## Examples
 
-Read from three CSV files sequentially:
+A common use case might be to generate a message at the end of our main input:
 
 ` + "```yaml" + `
 input:
   sequence:
     inputs:
-      - file:
-          format: csv
-          path: ./first.csv
-      - file:
-          format: csv
-          path: ./second.csv
-      - file:
-          format: csv
-          path: ./third.csv
-` + "```" + ``,
+      - csv:
+          paths: [ ./dataset.csv ]
+      - bloblang:
+          count: 1
+          mapping: 'root = {"status":"finished"}'
+` + "```" + `
+
+With this config once the records within ` + "`./dataset.csv`" + ` are exhausted
+our final payload ` + "`" + `{"status":"finished"}` + "`" + ` will be routed
+through the pipeline.`,
 		sanitiseConfigFunc: func(conf Config) (interface{}, error) {
 			inputsSanit := make([]interface{}, 0, len(conf.Sequence.Inputs))
 			for _, in := range conf.Sequence.Inputs {

website/docs/components/inputs/sequence.md

@@ -39,20 +39,20 @@ Default: `[]`
 
 ## Examples
 
-Read from three CSV files sequentially:
+A common use case might be to generate a message at the end of our main input:
 
 ```yaml
 input:
   sequence:
     inputs:
-      - file:
-          format: csv
-          path: ./first.csv
-      - file:
-          format: csv
-          path: ./second.csv
-      - file:
-          format: csv
-          path: ./third.csv
+      - csv:
+          paths: [ ./dataset.csv ]
+      - bloblang:
+          count: 1
+          mapping: 'root = {"status":"finished"}'
 ```
 
+With this config once the records within `./dataset.csv` are exhausted
+our final payload `{"status":"finished"}` will be routed
+through the pipeline.
+