Невозможно понять распараллеленный вывод кода в Ray

Question

Если я правильно понимаю, следующий фрагмент кода должен работать параллельно

@ray.remote
class Worker:
  ...

  def train(self, item, i):
    time.sleep(i)
    logging.info(f'{i} {item}')
...

worker = Worker.remote()
list = ['a', 'b', 'c']
results = ray.get([worker.train.remote(item, len(list) - idx) for idx, item in enumerate(list)])
print(results)
logging.info("successful print")

Это должно вывести

1 c
2 b
3 a
[1,2,3]

Однако, это выдает:

3 a
2 b
[3,2,1]

Я новичок в использовании Ray и не могу понять это поведение. Если бы кто-нибудь мог указать мне правильное направление, это было бы здорово!

Answer 1

Актер работает в рамках одного процесса. В результате worker.train.remote () будет синхронным.