|
8 | 8 | #include <ydb/core/external_sources/object_storage/events.h> |
9 | 9 | #include <ydb/library/actors/core/actor_bootstrapped.h> |
10 | 10 | #include <ydb/library/actors/core/hfunc.h> |
| 11 | +#include <ydb/library/actors/core/log.h> |
11 | 12 | #include <ydb/public/api/protos/ydb_value.pb.h> |
12 | 13 |
|
| 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) |
13 | 22 |
|
14 | 23 | namespace NKikimr::NExternalSource::NObjectStorage::NInference { |
15 | 24 |
|
@@ -314,7 +323,7 @@ class TArrowInferencinator : public NActors::TActorBootstrapped<TArrowInferencin |
314 | 323 | } |
315 | 324 |
|
316 | 325 | void HandleFileError(TEvFileError::TPtr& ev, const NActors::TActorContext& ctx) { |
317 | | - Cout << "TArrowInferencinator::HandleFileError" << Endl; |
| 326 | + LOG_D("TArrowInferencinator", "HandleFileError: " << ev->Get()->Issues.ToOneLineString()); |
318 | 327 | ctx.Send(RequesterId_, new TEvInferredFileSchema(ev->Get()->Path, std::move(ev->Get()->Issues))); |
319 | 328 | } |
320 | 329 |
|
|
0 commit comments