def METHOD_NAME(opts, sid, num=10, size=250000 * 3):
    server_channel = salt.channel.server.PubServerChannel.factory(opts)
    for idx in range(num):
        load = {
            "tgt_type": "glob",
            "tgt": "*",
            "jid": "{}-l{}".format(sid, idx),
            "xdata": "0" * size,
        }
        server_channel.publish(load)
    time.sleep(0.3)
    server_channel.close_pub()