Make `start_async()` available to source stages #1523

efajardo-nv · 2024-02-16T18:13:00Z

Description

Moves start_async from Stage to StageBase to make it available to source stages.
Adds tests for source stage start_async and on_start.

Closes #1522

I am familiar with the Contributing Guidelines.
When the PR is ready for review, new or existing tests cover these changes.
When the PR is ready for review, the documentation is up to date with these changes.

morpheus/pipeline/pipeline.py

tests/pipeline/test_pipeline.py

…into source-stage-start-async

mdemoret-nv · 2024-02-22T19:27:19Z

/merge

move start_async to StageBase

3dd47d9

efajardo-nv added bug Something isn't working non-breaking Non-breaking change labels Feb 16, 2024

efajardo-nv self-assigned this Feb 16, 2024

efajardo-nv requested a review from a team as a code owner February 16, 2024 18:13

pylint disable too many public methods

b290ee5

mdemoret-nv added breaking Breaking change and removed non-breaking Non-breaking change labels Feb 21, 2024

mdemoret-nv changed the title ~~Make start_async available to source stages~~ Make start_async() available to source stages Feb 21, 2024

mdemoret-nv approved these changes Feb 21, 2024

View reviewed changes

morpheus/pipeline/pipeline.py Outdated Show resolved Hide resolved

tests/pipeline/test_pipeline.py Outdated Show resolved Hide resolved

efajardo-nv added 2 commits February 21, 2024 16:07

Merge branch 'branch-24.03' of https://github.com/nv-morpheus/Morpheus …

9326c3a

…into source-stage-start-async

pr feedback updates

e854166

rapids-bot bot merged commit 65552f5 into nv-morpheus:branch-24.03 Feb 22, 2024
9 checks passed

efajardo-nv deleted the source-stage-start-async branch July 29, 2024 21:10