Skip to content

Commit 1fa2047

Browse files
committed
Cleanup
1 parent f2d4aa3 commit 1fa2047

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

ydb/library/yql/providers/s3/actors/yql_s3_read_actor.cpp

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1193,10 +1193,11 @@ class TS3ReadCoroImpl : public TActorCoroImpl {
11931193
CpuTime += GetCpuTimeDelta();
11941194

11951195
auto issues = NS3Util::AddParentIssue(TStringBuilder{} << "Error while reading file " << Path, std::move(Issues));
1196-
if (issues)
1196+
if (issues) {
11971197
Send(ComputeActorId, new IDqComputeActorAsyncInput::TEvAsyncInputError(InputIndex, std::move(issues), FatalCode));
1198-
else
1198+
} else {
11991199
Send(ParentActorId, new TEvS3Provider::TEvFileFinished(PathIndex, TakeIngressDelta(), TakeCpuTimeDelta(), RetryStuff->SizeLimit));
1200+
}
12001201
}
12011202

12021203
void ProcessUnexpectedEvent(TAutoPtr<IEventHandle> ev) {
@@ -1872,7 +1873,7 @@ class TS3StreamReadActor : public TActorBootstrapped<TS3StreamReadActor>, public
18721873
}
18731874

18741875
bool ConsumedEnoughRows() const noexcept {
1875-
return Blocks.empty() && RowsRemained && *RowsRemained == 0;
1876+
return RowsRemained && *RowsRemained == 0;
18761877
}
18771878

18781879
const TS3ReadActorFactoryConfig ReadActorFactoryCfg;

0 commit comments

Comments
 (0)