Skip to content

Preserve flow execution after 20 minutes if it do any activity #129

@kirill-levitskiy

Description

@kirill-levitskiy

There is an issue with a flow processing that stops accidentally after 20 minutes of execution.
Here is a line in the code that describes a constant for timeout in case of Running flow after 20 minutes

const TIMEOUT = process.env.ELASTICIO_TIMEOUT || 20 * 60 * 1000; // 20 minutes

The case:

  1. Create a flow;
  2. First step generates an array with 7000 int values;
  3. Second step (code-component) emits each array item individually with delay (500 ms).
  4. Run a flow.

An execution will continue 20 minutes and it stop emit messages even if an amount is less than 7000.

As a solution, there should be checked any activity during last 20 minutes before firing a timeout operation in order to keep a flow alive if it is still doing any job.

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions