fix(s3-aggreg): do not handle `{error, closed}` on buffer write
Because it's not really something `file:write/2` is supposed to return.
This commit is contained in:
parent
4bea938ef2
commit
6d3add3646
|
@ -94,7 +94,7 @@ write_records(Name, Buffer = #buffer{fd = Writer}, Records) ->
|
|||
ok ->
|
||||
?tp(s3_aggreg_records_written, #{action => Name, records => Records}),
|
||||
ok;
|
||||
{error, Reason} when Reason == terminated orelse Reason == closed ->
|
||||
{error, terminated} ->
|
||||
BufferNext = rotate_buffer(Name, Buffer),
|
||||
write_records(Name, BufferNext, Records);
|
||||
{error, _} = Error ->
|
||||
|
|
Loading…
Reference in New Issue