How severe does this issue affect your experience of using Ray?
- None: Just asking a question out of curiosity
- Low: It annoys or frustrates me for a moment.
- Medium: It contributes to significant difficulty to complete my task, but I can work around it.
- High: It blocks me to complete my task.
I am trying to apply ray
to a transformer pipeline as:
@ray.remote
def predict(pipeline, text_data, max_length, min_length, do_sample):
return pipeline(text_data, max_length, min_length, do_sample)
and initializing as:
predictions = ray.get(predict.remote(pipe_1, section, max_length=some_length, min_length=some_length, do_sample=False))
the pipeline pipe_1
is defined using ray.put()
pipe_1 = ray.put("transformer pipeline method definition")
Pipeline method definition is similar to as described here. I have initialized ray.init()
as :
ray.init(num_cpus=num_cpus, ignore_reinit_error=True)
However its seems my *args
are being ignored. Looks like max_length
, min_length
and do_sample
arguments are ignored - below is the sample console output:
(predict pid=19440) Ignoring args : (529, 423, False)
(predict pid=19440) Ignoring args : (680, 544, False)
Any suggestions.