@pipeline_operation
async def print(self, message):
    print(f'[FINAL OUT]: {message}')
    (await asyncio.sleep(random.randint(1, 5)))
@pipeline_operation
async def print(self, message):
    print(f'[FINAL OUT]: {message}')
    (await asyncio.sleep(random.randint(1, 5)))