Comment 0 for bug 1892043

Revision history for this message
ITD27M01 (igortiunov) wrote :

Hi Guys.

In a distributed environment (4 servers with engine/executor on each) we are experiencing issue with the following example workflow:

~~~
---
version: '2.0'

with-items-retry-concurency:
  type: direct

  task-defaults:
    concurrency: 10

  tasks:
    with-items:
      action: std.echo
      with-items: int in <% range(0,20) %>
      input:
        output: <% $.int %>
      retry:
        count: 5
        delay: 3
        continue-on: <% task().result %>
      publish:
        result: <% task().result %>

~~~

Mistral publishes wrong result for some reason:

~~~
[
    0,
    1,
    2,
    3,
    4,
    5,
    6,
    7,
    8,
    9,
    10,
    10,
    11,
    11,
    12,
    12,
    13,
    13,
    14,
    14
]
~~~

In the case of concurrency: 1 the result is OK:

~~~
[
    0,
    1,
    2,
    3,
    4,
    5,
    6,
    7,
    8,
    9,
    10,
    11,
    12,
    13,
    14,
    15,
    16,
    17,
    18,
    19
]
~~~

In the case of concurrency equal to with-items count (20 in the case of example workflow) it is OK too:

~~~
[
    0,
    1,
    2,
    3,
    4,
    5,
    6,
    7,
    8,
    9,
    10,
    11,
    12,
    13,
    14,
    15,
    16,
    17,
    18,
    19
]
~~~