Обертывание в Task.async вызывает странное поведение, что я не понимаю

Question

Рассмотрим следующие фрагменты кода:

)

IO.puts "test1" 
task = Task.async fn -> 
    Foo.Bar.send_file_for_processing(file_url) 
end 
IO.puts "test2" 
content = Task.await(task) 
IO.puts "test4" 

б)

IO.puts "test1" 
content = Foo.Bar.send_file_for_processing(file_url) 
IO.puts "test2" 

и в Foo. Барный модуль:

def send_file_for_processing(file_url) do 
    json = file_url |> encoded_file |> request_json 
    IO.puts "test3" 
    request = HTTPoison.post(
    @processing_endpoint, 
    json, 
    @headers, 
    params: %{"key": @api_key}, connect_timeout: 100000, recv_timeout: 100000, timeout: 100000 
) 
    IO.puts "test5" 

    (...) 
end 

Wh ru Я использую фрагмент кода a), «test5» никогда не был достигнут, как если бы программа зависала во время запроса HTTPOison POST. Он просто не заканчивается. Между тем, со сниппетом b), HTTPoison POST-запрос завершается нормально и без каких-либо задержек.

Если честно, отладка этого заставила меня потерять некоторое время, и я до сих пор не понимаю проблему со сниппетом а). Я неправильно использую модуль Task? Я проверил документацию и не нашел ничего, что могло бы объяснить мне эту проблему.

EDIT: Выход для сниппета а)

test1 
test2 
test3 

Answer 1

Я вижу, что высокие значения тайм-аута для запроса HTTP. Задача имеет значение тайм-аута по умолчанию 5_000 ms, поэтому очень вероятно, что таймауты задачи перед запросом будут завершены. Впоследствии задача убита, и вы никогда не увидите результат. Функция Task.await/2 принимает таймаут в качестве второго аргумента.

Независимо от того, что вы должны видеть ошибки таймаута задачи. Возможно, вы игнорируете некоторые результаты?