Take a load and send it across the network to connected minions
(self, load)
| 4145 | return jid |
| 4146 | |
| 4147 | async def _send_pub(self, load): |
| 4148 | """ |
| 4149 | Take a load and send it across the network to connected minions |
| 4150 | """ |
| 4151 | if not self.channels: |
| 4152 | for transport, opts in iter_transport_opts(self.opts): |
| 4153 | chan = salt.channel.server.PubServerChannel.factory(opts) |
| 4154 | self.channels.append(chan) |
| 4155 | tasks = set() |
| 4156 | for chan in self.channels: |
| 4157 | tasks.add(asyncio.create_task(chan.publish(load))) |
| 4158 | await asyncio.gather(*tasks) |
| 4159 | |
| 4160 | @property |
| 4161 | def ssh_client(self): |