Skip to content

chore: investigate Filter streams limit #2438

Open
@weboko

Description

@weboko

Description

It seems that Filter test for 30 simultaneous streams doesn't succeed in CI

Solution

We need to investigate

Logs

 1) Waku Filter Next: Subscribe: Multiple Service Nodes: Strict Check mode: true
       Subscribe to 30 topics in separate streams (30 streams for Filter is limit) at once and receives messages:
     Error: Failed to create a new stream for 16Uiu2HAkwLePcMU1bmx4GFyr2QTbKFD4uQkxGVVSd94WkBZvzZkW -- AbortError: The operation was aborted
      at StreamManager.createStream (file:///home/runner/work/js-waku/js-waku/packages/core/src/lib/stream_manager/stream_manager.ts:80:13)
      at runNextTicks (node:internal/process/task_queues:65:5)
      at listOnTimeout (node:internal/timers:549:9)
      at processTimers (node:internal/timers:523:7)
      at async StreamManager.getStream (file:///home/runner/work/js-waku/js-waku/packages/core/src/lib/stream_manager/stream_manager.ts:45:14)
      at async FilterCore.subscribe (file:///home/runner/work/js-waku/js-waku/packages/core/src/lib/filter/filter.ts:91:20)
      at async Subscription.requestSubscribe (file:///home/runner/work/js-waku/js-waku/packages/sdk/src/filter/subscription.ts:511:22)
      at async Promise.all (index 0)
      at async Subscription.attemptSubscribe (file:///home/runner/work/js-waku/js-waku/packages/sdk/src/filter/subscription.ts:480:21)
      at async Subscription.add (file:///home/runner/work/js-waku/js-waku/packages/sdk/src/filter/subscription.ts:143:9)

  2) Waku Filter Next: Subscribe: Multiple Service Nodes: Strict Check mode: false
       Subscribe to 30 topics in separate streams (30 streams for Filter is limit) at once and receives messages:
     Error: Failed to create a new stream for 16Uiu2HAmFXTis3DeMsRg6BPCnyNE3aV6ZNV4mzzRThGvHymcBpNt -- AbortError: The operation was aborted
      at StreamManager.createStream (file:///home/runner/work/js-waku/js-waku/packages/core/src/lib/stream_manager/stream_manager.ts:80:13)
      at runNextTicks (node:internal/process/task_queues:65:5)
      at listOnTimeout (node:internal/timers:549:9)
      at processTimers (node:internal/timers:523:7)
      at async StreamManager.getStream (file:///home/runner/work/js-waku/js-waku/packages/core/src/lib/stream_manager/stream_manager.ts:45:14)
      at async FilterCore.subscribe (file:///home/runner/work/js-waku/js-waku/packages/core/src/lib/filter/filter.ts:91:20)
      at async Subscription.requestSubscribe (file:///home/runner/work/js-waku/js-waku/packages/sdk/src/filter/subscription.ts:511:22)
      at async Promise.all (index 0)
      at async Subscription.attemptSubscribe (file:///home/runner/work/js-waku/js-waku/packages/sdk/src/filter/subscription.ts:480:21)
      at async Subscription.add (file:///home/runner/work/js-waku/js-waku/packages/sdk/src/filter/subscription.ts:143:9)

Metadata

Metadata

Assignees

No one assigned

    Labels

    maintenanceMarks maintenance type of tasks.testIssue related to the test suite with no expected consequence to production code

    Type

    Projects

    Status

    Triage

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions