Core Plugins and tasks Put
CertifiedUpdate an existing Key-Value entry
Core Plugins and tasks Put
Update an existing Key-Value entry
Renders key, value, and namespace (defaults to the Flow namespace), then writes to the namespace KV store.
Map values are deep merged (nested object keys are preserved); keyed entries like [{key: ..., value: ...}] update JSON fields (dotted paths allowed) while [{value: ...}] replaces the entire value. Set errorOnMissing to true to fail when the key is absent, otherwise a new key-value pair is created.
type: io.kestra.plugin.core.kv.PutExamples
Replace a string value
id: kv_put_string
namespace: company.team
tasks:
- id: update_my_string
type: io.kestra.plugin.core.kv.Put
key: my-string-key
value: "new-value"
Insert or update JSON keys
id: kv_put_json
namespace: company.team
tasks:
- id: update_my_json
type: io.kestra.plugin.core.kv.Put
key: my-json-key
value:
- key: "json-key-1"
value: "my new value"
- key: "nested.field"
value: 123
Properties
key *string
Key to update
Key name within the target namespace
value *object
Value payload to write
Maps are deep merged and entry lists can replace or patch JSON fields
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
{}1150errorOnMissing booleanstring
falseFail when key is absent
Default false; when true throws before writing if the key does not exist
namespace string
{{ flow.namespace }}Target namespace
Defaults to the current Flow namespace; accepts expressions
