Last updated
| Operator | Description |
|---|
| call | Calls another workflow |
| http_call | Call workflow fetched by HTTP |
| require | Depends on another workflow |
| loop | Repeat tasks |
| for_each | Repeat tasks for values |
| for_range | Repeat tasks for a range |
| if | Conditional execution |
| fail | Makes the workflow failed |
| echo | Shows a message |
| wait | Wait for a specific duration |
| Operator | Description |
|---|
| mail | Sending email |
| http | Making HTTP requests |
| Operator | Description |
|---|
| pg | PostgreSQL operations |
Amazon Web Services Operators
| Operator | Description |
|---|
| gcs_wait | Wait for a file in Google Cloud Storage |
| bq | Running Google BigQuery queries |
| bq_ddl | Managing Google BigQuery Datasets and Tables |
| bq_extract | Exporting Data from Google BigQuery |
| bq_load | Importing Data into Google BigQuery |
| Operator | Description |
|---|
| py | Python scripts |
Unsupported Digdag Operators
| Operator | Description |
|---|
| embulk | Embulk data transfer |
| emr | Running Amazon EMR jobs |
| sh | Running shell scripts |
| rb | Running Ruby scripts |
| param_get | Getting persistent data |
| param_set | Storing persistent data |