Skip to content

Commit 20635ca

Browse files
minor style fixes (#7907)
1 parent a78e0d6 commit 20635ca

File tree

3 files changed

+12
-2
lines changed

3 files changed

+12
-2
lines changed

ydb/core/external_sources/object_storage.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -361,13 +361,13 @@ struct TObjectStorageExternalSource : public IExternalSource {
361361
metaPromise.SetValue(NYql::NCommon::ResultFromError<TMetadataResult>(response.Status.GetIssues()));
362362
return;
363363
}
364-
TMetadataResult result;
365364
meta->Changed = true;
366365
meta->Schema.clear_column();
367366
for (const auto& column : response.Fields) {
368367
auto& destColumn = *meta->Schema.add_column();
369368
destColumn = column;
370369
}
370+
TMetadataResult result;
371371
result.SetSuccess();
372372
result.Metadata = meta;
373373
metaPromise.SetValue(std::move(result));

ydb/core/external_sources/object_storage/inference/arrow_inferencinator.cpp

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,8 +8,17 @@
88
#include <ydb/core/external_sources/object_storage/events.h>
99
#include <ydb/library/actors/core/actor_bootstrapped.h>
1010
#include <ydb/library/actors/core/hfunc.h>
11+
#include <ydb/library/actors/core/log.h>
1112
#include <ydb/public/api/protos/ydb_value.pb.h>
1213

14+
#define LOG_E(name, stream) \
15+
LOG_ERROR_S(*NActors::TlsActivationContext, NKikimrServices::OBJECT_STORAGE_INFERENCINATOR, name << ": " << this->SelfId() << ". " << stream)
16+
#define LOG_I(name, stream) \
17+
LOG_INFO_S(*NActors::TlsActivationContext, NKikimrServices::OBJECT_STORAGE_INFERENCINATOR, name << ": " << this->SelfId() << ". " << stream)
18+
#define LOG_D(name, stream) \
19+
LOG_DEBUG_S(*NActors::TlsActivationContext, NKikimrServices::OBJECT_STORAGE_INFERENCINATOR, name << ": " << this->SelfId() << ". " << stream)
20+
#define LOG_T(name, stream) \
21+
LOG_TRACE_S(*NActors::TlsActivationContext, NKikimrServices::OBJECT_STORAGE_INFERENCINATOR, name << ": " << this->SelfId() << ". " << stream)
1322

1423
namespace NKikimr::NExternalSource::NObjectStorage::NInference {
1524

@@ -314,7 +323,7 @@ class TArrowInferencinator : public NActors::TActorBootstrapped<TArrowInferencin
314323
}
315324

316325
void HandleFileError(TEvFileError::TPtr& ev, const NActors::TActorContext& ctx) {
317-
Cout << "TArrowInferencinator::HandleFileError" << Endl;
326+
LOG_D("TArrowInferencinator", "HandleFileError: " << ev->Get()->Issues.ToOneLineString());
318327
ctx.Send(RequesterId_, new TEvInferredFileSchema(ev->Get()->Path, std::move(ev->Get()->Issues)));
319328
}
320329

ydb/library/services/services.proto

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -346,6 +346,7 @@ enum EServiceKikimr {
346346

347347
DB_POOL = 1167;
348348
YTS = 1168;
349+
OBJECT_STORAGE_INFERENCINATOR = 1169;
349350

350351
// 1024 - 1099 is reserved for nbs
351352

0 commit comments

Comments
 (0)