docs: def cli(ctx, amount, index, stage):
      """Pull, Transform, Push,streaming inside a pipe(experimental)."""
      ctx.obj.say_green('Starting Streaming Pipe')
      res_pull = ctx.invoke(pull, amount=amount, index=index, stage=stage)
      res_tra = False
      if res_pull:
          # amount to transform can be less (or more)
          res_tra = ctx.invoke(
              transform, amount=amount, index=index, stage=stage)
      if res_tra:
          # amount to push can be less (or more)
          res_push = ctx.invoke(push, amount=amount, index=index, stage=stage)
      if res_pull and res_tra and res_push:
          ctx.obj.say_green('Streaming Pipe finsished')
          return True
      return False