Getting started with Workflows

1. In the top-right corner, click Create function.
2. Enter the function name: filter-function.
3. Click Create.

1. In the Editor window that opens, select Node.js 22.
2. Disable Add files with code examples.
3. Click Continue.
4. Create a file named index.js and add the following code into it:

   module.exports.handler = async function (data, context) {
       return {
           id: data.id,
           name: data.name,
           email: data.email,
       };
   };
   

5. Under Parameters, specify the following in the field:
   • Entry point: index.handler
   • Service account: sa-for-function
6. Click Save changes.

1. In the top-right corner, click Create function.
2. Enter the function name: return-function.
3. Click Create.

1. In the Editor window that opens, select Node.js 22.
2. Disable Add files with code examples.
3. Click Continue.
4. Create a file named index.js and add the following code into it:

   module.exports.handler = async function (data, context) {
       return {
           result: "OK",
           emails: data.loaded_users.map(p => p.email)
       };
   };
   

5. Under Parameters, specify the following in the field:
   • Entry point: index.handler
   • Service account: sa-for-function
6. Click Save changes.

In the management console, select the folder where you want to create a workflow.

Go to Serverless Integrations.

In the left-hand panel, select Workflows.

In the top-right corner, click Create workflow.

In the YaML specification field, add the specification below. In the functionId field:

• In line 39, step process_user_transform_info, specify the filter-function ID.
• In line 44, step upload_users, specify the return-function ID.

yawl: "0.1"
start: get_users
defaultRetryPolicy:
  maxDelay: 10s
  retryCount: 2
  errorList:
    - STEP_QUOTA_EXCEEDED
steps:
  get_users:
    httpCall:
      url: 'https://jsonplaceholder.typicode.com/\(.resource_type)'
      method: GET
      headers: {}
      query: {}
      output: '\({loaded_users: .})'
      next: process_users
  process_users:
    foreach:
      input: \(.loaded_users)
      output: '\({loaded_users: .})'
      next: upload_users
      do:
        start: process_user_get_info
        steps:
          process_user_get_info:
            httpCall:
              url: https://jsonplaceholder.typicode.com/users/\(.id)
              method: GET
              headers: {}
              query: {}
              next: process_user_transform_info
              output: '\({user: .})'
              retryPolicy:
                retryCount: 2
                errorList:
                  - HTTP_CALL_500
          process_user_transform_info:
            functionCall:
              functionId: <function_ID>
  upload_users:
    functionCall:
      functionId: "<function_ID>"
      input: '\({loaded_users, resource_type})'

Expand the Additional parameters section:

In the Name field, enter the workflow name.

In the Service account field, select the sa-for-function service account.

Click Create.

Select a workflow.

In the top-right corner, click Execute.

Enter input data in JSON format and click Execute.

Input data in JSON format:

{
  "resource_type": "users"
}

When the workflow status changes from Running to Completed, the following JSON formatted result will appear in the Output data section:

{
  "result": "OK",
  "emails": [
    "Sincere@april.biz",
    "Shanna@melissa.tv",
    "Nathan@yesenia.net",
    "Julianne.OConner@kory.org",
    "Lucio_Hettinger@annie.ca",
    "Karley_Dach@jasper.info",
    "Telly.Hoeger@billy.biz",
    "Sherwood@rosamond.me",
    "Chaim_McDermott@dana.io",
    "Rey.Padberg@karina.biz"
  ]
}