Prefix the queue/stage order

[mthrok]

So that it's easier to check the stats in the log.

import logging

from spdl.pipeline import PipelineBuilder

logging.basicConfig(level=logging.INFO)

pipeline = (
    PipelineBuilder()
    .add_source(range(10))
    .pipe(lambda x: x+1, name="add1")
    .pipe(lambda x: 2 * x, name="x2")
    .aggregate(3)
    .pipe(sum)
    .aggregate(2)
    .disaggregate()
    .add_sink()
    .build(num_threads=1)
)
with pipeline.auto_stop():
    for _ in pipeline:
        pass

INFO:spdl.pipeline._queue:[0:src_queue]			Processed    10 items in    2.6 [ ms] (QPS: 3809.5) Ave wait time: put:    0.1 [ ms], get (by next stage):    0.0 [ ms].
INFO:spdl.pipeline._queue:[1:add1_queue]		Processed    10 items in    2.9 [ ms] (QPS: 3432.4) Ave wait time: put:    0.0 [ ms], get (by next stage):    0.0 [ ms].
INFO:spdl.pipeline._queue:[2:x2_queue]			Processed    10 items in    3.3 [ ms] (QPS: 3018.1) Ave wait time: put:    0.0 [ ms], get (by next stage):    0.1 [ ms].
INFO:spdl.pipeline._queue:[3:aggregate(3)_queue]	Processed    11 items in    3.8 [ ms] (QPS: 2889.0) Ave wait time: put:    0.0 [ ms], get (by next stage):    0.2 [ ms].
INFO:spdl.pipeline._queue:[4:sum_queue]			Processed     4 items in    4.0 [ ms] (QPS:  998.1) Ave wait time: put:    0.0 [ ms], get (by next stage):    0.7 [ ms].
INFO:spdl.pipeline._queue:[5:aggregate(2)_queue]	Processed     5 items in    4.5 [ ms] (QPS: 1102.1) Ave wait time: put:    0.0 [ ms], get (by next stage):    0.6 [ ms].
INFO:spdl.pipeline._queue:[6:disaggregate_queue]	Processed     4 items in    4.6 [ ms] (QPS:  871.2) Ave wait time: put:    0.0 [ ms], get (by next stage):    1.1 [ ms].
INFO:spdl.pipeline._queue:[7:sink_queue]		Processed     4 items in    4.6 [ ms] (QPS:  863.2) Ave wait time: put:    0.0 [ ms], get (by next stage):    0.9 [ ms].

INFO:spdl.pipeline._hook:[1:add1]		Completed    10 tasks (  0 failed). (Concurrency:   1). Ave task time:    0.1 [ ms].
INFO:spdl.pipeline._hook:[2:x2]			Completed    10 tasks (  0 failed). (Concurrency:   1). Ave task time:    0.1 [ ms].
INFO:spdl.pipeline._hook:[3:aggregate(3)]	Completed    11 tasks (  0 failed). (Concurrency:   1). Ave task time:    0.1 [ ms].
INFO:spdl.pipeline._hook:[4:sum]		Completed     4 tasks (  0 failed). (Concurrency:   1). Ave task time:    0.2 [ ms].
INFO:spdl.pipeline._hook:[5:aggregate(2)]	Completed     5 tasks (  0 failed). (Concurrency:   1). Ave task time:    0.1 [ ms].
INFO:spdl.pipeline._hook:[6:disaggregate]	Completed     4 tasks (  0 failed). (Concurrency:   1). Ave task time:    0.2 [ ms].

[facebook-github-bot]

@facebook-github-bot has imported this pull request. If you are a Meta employee, you can view this diff on Phabricator. (Because this pull request was imported automatically, there will not be any future comments.)