code: async def trigger_all(self, *args, **kwargs):
          
          async def slave_task(addr, *args, **kwargs):
              r_manager = await self.env.connect(addr, timeout=TIMEOUT)
              return await r_manager.trigger_all(*args, **kwargs)
  
          return await create_tasks(slave_task, self.addrs, *args, **kwargs)
docs: Trigger all agents in all the slave environments to :meth:`act`
          asynchronously.
  
          Given arguments and keyword arguments are passed down to each agent's
          :meth:`creamas.core.agent.CreativeAgent.act`.
  
          .. note::
  
              By design, the manager agents in each slave environment, i.e.
              :attr:`manager`, are excluded from acting.