RedisCLI 
RedisCLI
yaml
type: "io.kestra.plugin.redis.cli.RedisCLI"Examples
yaml
id: redis_cli_example
namespace: company.team
tasks:
- id: redis_cli
type: io.kestra.plugin.redis.cli.RedisCLI
host: localhost
port: 6379
commands:
- SET mykey "Hello World"
- GET mykey
yaml
id: redis_cli_auth
namespace: company.team
tasks:
- id: redis_cli
type: io.kestra.plugin.redis.cli.RedisCLI
host: localhost
port: 6379
password: "{{ secret('REDIS_PASSWORD') }}"
commands:
- LPUSH mylist "item1"
- LPUSH mylist "item2"
- LRANGE mylist 0 -1
jsonOutput: true
yaml
id: redis_cli_custom_image
namespace: company.team
tasks:
- id: redis_cli
type: io.kestra.plugin.redis.cli.RedisCLI
host: redis.example.com
port: 6379
database: 2
username: myuser
password: "{{ secret('REDIS_PASSWORD') }}"
containerImage: redis:7-alpine
commands:
- INFO server
- DBSIZE
Properties
commands *Requiredarray
SubTypestring
host *Requiredstring
containerImage string
Default
redis:7-alpinedatabase integerstring
Default
0docker string
Default
{"pullPolicy":"IF_NOT_PRESENT"} Definitions
io.kestra.plugin.scripts.exec.scripts.models.DockerOptions
image*Requiredstring
Min length
1configstringobject
cpu
io.kestra.plugin.scripts.runner.docker.Cpu
cpusnumberstring
credentials
Credentials for a private container registry.
authstring
identityTokenstring
passwordstring
registrystring
registryTokenstring
usernamestring
deviceRequestsarray
A request for devices to be sent to device drivers.
capabilitiesarray
SubTypearray
countintegerstring
deviceIdsarray
SubTypestring
driverstring
optionsobject
SubTypestring
entryPointarray
SubTypestring
extraHostsarray
SubTypestring
hoststring
memory
io.kestra.plugin.scripts.runner.docker.Memory
kernelMemorystring
memorystring
memoryReservationstring
memorySwapstring
memorySwappinessstring
oomKillDisablebooleanstring
networkModestring
privilegedbooleanstring
pullPolicystring
Default
IF_NOT_PRESENTPossible Values
IF_NOT_PRESENTALWAYSNEVERshmSizestring
userstring
volumesarray
SubTypestring
env object
SubTypestring
inputFiles objectstring
jsonOutput booleanstring
Default
falsenamespaceFiles Non-dynamic
Definitions
io.kestra.core.models.tasks.NamespaceFiles
enabledbooleanstring
Default
trueexcludearray
SubTypestring
folderPerNamespacebooleanstring
Default
falseifExistsstring
Default
OVERWRITEPossible Values
OVERWRITEFAILWARNIGNOREincludearray
SubTypestring
namespacesarray
SubTypestring
Default
["{{flow.namespace}}"]outputFiles array
SubTypestring
password string
port integerstring
Default
6379taskRunner Non-dynamic
Definitions
Run a task in a Docker container.
type*Requiredobject
configstringobject
cpu
io.kestra.plugin.scripts.runner.docker.Cpu
cpusnumberstring
credentials
Credentials for a private container registry.
authstring
identityTokenstring
passwordstring
registrystring
registryTokenstring
usernamestring
deletebooleanstring
Default
truedeviceRequestsarray
A request for devices to be sent to device drivers.
capabilitiesarray
SubTypearray
countintegerstring
deviceIdsarray
SubTypestring
driverstring
optionsobject
SubTypestring
entryPointarray
SubTypestring
Default
[
""
]extraHostsarray
SubTypestring
fileHandlingStrategystring
Default
VOLUMEPossible Values
MOUNTVOLUMEhoststring
killGracePeriodstring
Default
PT0SFormat
durationmemory
io.kestra.plugin.scripts.runner.docker.Memory
kernelMemorystring
memorystring
memoryReservationstring
memorySwapstring
memorySwappinessstring
oomKillDisablebooleanstring
networkModestring
portBindingsarray
SubTypestring
privilegedbooleanstring
pullPolicyobject
resumebooleanstring
Default
trueshmSizestring
userstring
versionstring
volumesarray
SubTypestring
waitbooleanstring
Default
trueTask runner that executes a task as a subprocess on the Kestra host.
type*Requiredobject
versionstring
Task runner that executes a task inside a job in Google Cloud Batch.
region*Requiredstring
type*Requiredobject
bucketstring
completionCheckIntervalstring
Default
PT5SFormat
durationcomputeResource
io.kestra.plugin.ee.gcp.runner.Batch-ComputeResource
bootDiskstring
cpustring
memorystring
deletebooleanstring
Default
trueentryPointarray
SubTypestring
impersonatedServiceAccountstring
lifecyclePoliciesarray
io.kestra.plugin.ee.gcp.runner.Batch-LifecyclePolicy
actionstring
Possible Values
ACTION_UNSPECIFIEDRETRY_TASKFAIL_TASKUNRECOGNIZEDactionCondition
io.kestra.plugin.ee.gcp.runner.Batch-LifecyclePolicyAction
exitCodesarray
SubTypeinteger
machineTypestring
Default
e2-mediummaxCreateJobRetryCountintegerstring
Default
2maxRetryCountinteger
Minimum
>= 0Maximum
<= 10networkInterfacesarray
io.kestra.plugin.ee.gcp.runner.Batch-NetworkInterface
network*Requiredstring
subnetworkstring
projectIdstring
reservationstring
resumebooleanstring
Default
truescopesarray
SubTypestring
Default
["https://www.googleapis.com/auth/cloud-platform"]serviceAccountstring
syncWorkingDirectorybooleanstring
Default
falseversionstring
waitForLogIntervalstring
Default
PT5SFormat
durationwaitUntilCompletionstring
Default
PT1HFormat
durationTask runner that executes a task inside a job in Google Cloud Run.
region*Requiredstring
type*Requiredobject
bucketstring
completionCheckIntervalstring
Default
PT5SFormat
durationdeletebooleanstring
Default
trueimpersonatedServiceAccountstring
maxRetriesintegerstring
Default
3projectIdstring
resumebooleanstring
Default
truescopesarray
SubTypestring
Default
["https://www.googleapis.com/auth/cloud-platform"]serviceAccountstring
syncWorkingDirectorybooleanstring
versionstring
vpcAccessConnectorstring
vpcEgressstring
Possible Values
VPC_EGRESS_UNSPECIFIEDALL_TRAFFICPRIVATE_RANGES_ONLYUNRECOGNIZEDwaitForLogIntervalstring
Default
PT5SFormat
durationwaitUntilCompletionstring
Default
PT1HFormat
durationTask runner that executes a task inside a job in Azure Batch.
account*Requiredstring
endpoint*Requiredstring
poolId*Requiredstring
type*Requiredobject
accessKeystring
blobStorage
io.kestra.plugin.ee.azure.storage.blob.models.BlobStorageForBatch
containerName*Requiredstring
connectionStringstring
endpointstring
sharedKeyAccountAccessKeystring
sharedKeyAccountNamestring
completionCheckIntervalstring
Default
PT5SFormat
durationdeletebooleanstring
Default
trueregistry
io.kestra.plugin.ee.azure.batch.models.ContainerRegistry
identityReference
io.kestra.plugin.ee.azure.batch.models.ComputeNodeIdentityReference
resourceIdstring
passwordstring
registryServerstring
userNamestring
resumebooleanstring
Default
truestreamLogsbooleanstring
Default
falsesyncWorkingDirectorybooleanstring
Default
falseversionstring
waitUntilCompletionstring
Default
PT1HFormat
durationTask runner that executes a task inside a pod in a Kubernetes cluster.
type*Requiredobject
config
io.kestra.plugin.ee.kubernetes.models.Connection
apiVersionstring
Default
v1caCertDatastring
caCertFilestring
clientCertDatastring
clientCertFilestring
clientKeyAlgostring
Default
RSAclientKeyDatastring
clientKeyFilestring
clientKeyPassphrasestring
disableHostnameVerificationbooleanstring
keyStoreFilestring
keyStorePassphrasestring
masterUrlstring
Default
https://kubernetes.default.svcnamespacestring
oauthTokenstring
oauthTokenProvider
io.kestra.plugin.ee.kubernetes.models.OAuthTokenProvider
outputstring
task
passwordstring
trustCertsbooleanstring
trustStoreFilestring
trustStorePassphrasestring
usernamestring
containerDefaultSpecobject
containerSpecobject
deletebooleanstring
Default
truefileSideCarSpecobject
fileSidecar
Default
{
"image": "busybox"
}io.kestra.plugin.ee.kubernetes.runner.SideCar
defaultSpecobject
imagestring
Default
busyboxresourcesobject
killed
Default
falsejava.util.concurrent.atomic.AtomicBoolean
labelsobject
namespacestring
Default
defaultnodeSelectorobject
podSpecobject
pullPolicystring
Default
ALWAYSPossible Values
IF_NOT_PRESENTALWAYSNEVERresources
io.kestra.plugin.ee.kubernetes.runner.Kubernetes-Resources
limit
io.kestra.plugin.ee.kubernetes.runner.Kubernetes-Resource
cpustring
memorystring
request
io.kestra.plugin.ee.kubernetes.runner.Kubernetes-Resource
cpustring
memorystring
resumebooleanstring
Default
trueserviceAccountNamestring
syncWorkingDirectorybooleanstring
Default
falseversionstring
waitForLogsstring
Default
PT30SFormat
durationwaitUntilCompletionstring
Default
PT1HFormat
durationwaitUntilRunningstring
Default
PT10MFormat
durationTask runner that executes a task inside a job in AWS Batch.
computeEnvironmentArn*Requiredstring
region*Requiredstring
type*Requiredobject
accessKeyIdstring
bucketstring
completionCheckIntervalstring
Default
PT5SFormat
durationdeletebooleanstring
Default
trueendpointOverridestring
executionRoleArnstring
jobQueueArnstring
resources
Default
{
"request": {
"memory": "2048",
"cpu": "1"
}
}io.kestra.plugin.ee.aws.runner.Batch-Resources
request*Required
io.kestra.plugin.ee.aws.runner.Batch-Resource
cpu*Requiredstring
memory*Requiredstring
resumebooleanstring
Default
truesecretKeyIdstring
sessionTokenstring
sidecarResources
io.kestra.plugin.ee.aws.runner.Batch-Resources
request*Required
io.kestra.plugin.ee.aws.runner.Batch-Resource
cpu*Requiredstring
memory*Requiredstring
stsEndpointOverridestring
stsRoleArnstring
stsRoleExternalIdstring
stsRoleSessionDurationstring
Default
PT15MFormat
durationstsRoleSessionNamestring
syncWorkingDirectorybooleanstring
Default
falsetaskRoleArnstring
versionstring
waitUntilCompletionstring
Default
PT1HFormat
durationtls booleanstring
Default
falseusername string
Outputs
exitCode integer
Default
0outputFiles object
SubTypestring
taskRunner
Definitions
io.kestra.core.models.tasks.runners.TaskRunnerDetailResult
vars object
Metrics
executed.commands.count counter
Unit
commands
