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