S2 ListStreams
CertifiedList S2 streams
S2 ListStreams
List S2 streams
Lists streams in an S2 basin with optional prefix filtering and pagination.
type: io.kestra.plugin.s2.ListStreamsExamples
List streams
id: list_streams
namespace: company.team
tasks:
- id: list
type: io.kestra.plugin.s2.ListStreams
accessToken: "{{ secret('S2_ACCESS_TOKEN') }}"
basin: my-basin
limit: 100
Properties
accessToken *string
S2 access token
Access token used to authenticate with S2
basin *string
S2 basin
S2 basin containing the streams
assets
Assets this task consumes as inputs or produces as outputs, for lineage tracking and the asset graph (Enterprise Edition). A flow declaring this property on a task is rejected in the open-source edition.
io.kestra.core.models.assets.AssetsDeclaration
IGNOREFAILWARNAsset failure behavior
Behavior applied to the task state when a declared asset fails to render, emit, or be persisted (e.g. a lock conflict): FAIL escalates it to FAILED, WARN (default) warns it if it would otherwise succeed, IGNORE leaves the state untouched.
Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.
The assets consumed as inputs.
io.kestra.core.models.assets.AssetIdentifier
1The assets produced as outputs.
io.kestra.plugin.ee.assets.Dataset
1150{}1150io.kestra.plugin.ee.assets.File
1150{}1150io.kestra.plugin.ee.assets.Table
1150{}1150io.kestra.plugin.ee.assets.VM
1150{}1150io.kestra.core.models.assets.External
1150{}1150io.kestra.core.models.assets.Custom
11501Custom asset type
{}1150basinEndpoint string
https://{basin}.b.s2.dev/v1Basin endpoint
S2 basin API endpoint. The {basin} placeholder is replaced by the basin name. When the endpoint has no placeholder, the basin is sent in the S2-Basin header, which is how a custom endpoint such as s2-lite is addressed.
limit integerstring
1000Limit
Maximum number of streams to return.
prefix string
Prefix
Filters streams whose names begin with this prefix.
startAfter string
Start after
Returns streams whose names are lexicographically after this value.
Outputs
hasMore boolean
Has more
Whether more streams are available after this page.
streams array
Streams
The streams returned by S2, ordered by name.
io.kestra.plugin.s2.ListStreams-StreamInfo
Encryption cipher
Cipher used to encrypt the stream, if any.
Creation time
Time the stream was created.
Deletion time
Time the stream was marked for deletion, if any.
Stream name
Name of the stream.
