Job
Job descriptor
Properties
Name | Type | Description | Required |
---|---|---|---|
input | object | yes | |
steps | array | ||
error_handling | string | Error handling strategy: abort - terminate job, ignore - skip Default: "ignore" Enum: "abort" , "ignore" |
Additional Properties: not allowed
Example
error_handling: ignore
input: object
Properties
Name | Type | Description | Required |
---|---|---|---|
uses | string | Block type | yes |
with | array | Properties | no |
Additional Properties: not allowed
Example
uses: files.read_csv
with:
file: employees.csv
batch_size: 2500
Example
uses: add_field
with:
field: full_name
language: jmespath
expression: concat([capitalize(fname), ' ' , capitalize(lname)])
Example
uses: map
with:
expression:
id: id
full_name: full_name
country: country_code || ' - ' || UPPER(country_name)
gender: gender
Example
uses: redis.write
with:
connection: cache
command: HSET
key:
expression: id
language: jmespath
input.with[]: object,array
Properties
No properties.
steps[]: array
Items