code: def subscribe(self, *, create_task=True, **params):
          
          if create_task and not self.task:
              self.task = asyncio.ensure_future(self.run(**params))
          return self.channel.subscribe()
docs: Subscribes to the Docker events channel. Use the keyword argument
          create_task=False to prevent automatically spawning the background
          tasks that listen to the events.
  
          This function returns a ChannelSubscriber object.