@@ -797,7 +797,7 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
797797 }
798798 };
799799
800- struct TAsyncInputTransformHelper : TAsyncInputHelper{
800+ struct TAsyncInputTransformHelper : TAsyncInputHelper {
801801 NUdf::TUnboxedValue InputBuffer;
802802
803803 using TAsyncInputHelper::TAsyncInputHelper;
@@ -1242,7 +1242,7 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
12421242 IRandomProvider* randomProvider
12431243 )
12441244 {
1245- auto collectStatsLevel = StatsModeToCollectStatsLevel (RuntimeSettings.StatsMode );
1245+ auto collectStatsLevel = StatsModeToCollectStatsLevel (RuntimeSettings.StatsMode );
12461246 for (auto & [inputIndex, source] : SourcesMap) {
12471247 Y_ABORT_UNLESS (AsyncIoFactory);
12481248 const auto & inputDesc = Task.GetInputs (inputIndex);
@@ -1459,12 +1459,12 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
14591459
14601460private:
14611461 void InitializeTask () {
1462- for (ui32 i = 0 ; i < Task.InputsSize (); ++i) {
1462+ for (ui32 i = 0 ; i < Task.InputsSize (); ++i) {
14631463 const auto & inputDesc = Task.GetInputs (i);
14641464 Y_ABORT_UNLESS (!inputDesc.HasSource () || inputDesc.ChannelsSize () == 0 ); // HasSource => no channels
14651465
14661466 if (inputDesc.HasTransform ()) {
1467- auto result = InputTransformsMap.emplace (
1467+ auto result = InputTransformsMap.emplace (
14681468 i,
14691469 static_cast <TDerived*>(this )->template CreateInputHelper <TAsyncInputTransformHelper>(LogPrefix, i, NDqProto::WATERMARKS_MODE_DISABLED)
14701470 );
0 commit comments