def METHOD_NAME(*iargs):
    tasks = []
    buffers = []
    for i in range(len(iargs)):
        task = Ufo.InputTask()
        tasks.append(task)
        buffers.append(None)
        self.env.graph.connect_nodes_full(task, self.task, i)
    while not self.env.started:
        time.sleep(0.01)
    for args in zip(*iargs):
        for i, (task, data) in enumerate(zip(tasks, args)):
            if buffers[i] is None:
                buffers[i] = empty_like(data)
            else:
                buffers[i] = task.get_input_buffer()
            buffers[i].set_host_array(data.__array_interface__['data'][0], False)
            task.release_input_buffer(buffers[i])
    for task in tasks:
        task.stop()