проверить, какие ObjectID сделаны в луче - PullRequest
1 голос
/ 11 июня 2019

У меня есть несколько удаленных функций в Ray, представленных для расчетов.Прежде чем получить их с помощью ray.get, я хотел бы сначала проверить, выполнены ли они, чтобы я мог продолжать делать другие вещи, пока они вычисляют.

Кроме того, я действительно думаю о сохранении словаря с такой структурой

{
  { 'JSON of parameters used in the calculation': OBJECTid},
   ...
}

, чтобы я мог периодически читать этот словарь и собирать OBJECTid.Для этого мне нужно опросить диспетчер задач, чтобы узнать, завершен ли OBJECTid.

На этой странице Кажется, я вижу интересные функции, например, функцию ray.objects().Это, однако, кажется, недоступно в моей записной книжке, хотя я вижу многие другие функции, перечисленные там, например ray.init(), ray.shutdown() и т. Д. Все функции, перечисленные в Inspect the Cluster State, кажется, отсутствуют, может быть, япропущен какой-то важный шаг (импорт?)

1 Ответ

1 голос
/ 12 июня 2019

Оказывается, функции ray.wait это делают.Это ключ, чтобы установить тайм-аут на ноль, иначе будет блокировать ядро.

ready_ids, _remaining_ids = ray.wait([OBJECTid],timeout=0)
...