|
42 | 42 | namespace NYql {
|
43 | 43 | namespace NDq {
|
44 | 44 |
|
45 |
| -namespace { |
46 |
| - |
47 |
| -struct TEvPrivate { |
48 |
| - enum EEv : ui32 { |
49 |
| - EvRuntimeError = EventSpaceBegin(NActors::TEvents::ES_PRIVATE), |
50 |
| - EvEnd |
51 |
| - }; |
52 |
| - |
53 |
| - static_assert(EvEnd < EventSpaceEnd(NActors::TEvents::ES_PRIVATE), "expect EvEnd < EventSpaceEnd(TEvents::ES_PRIVATE)"); |
54 |
| - |
55 |
| - struct TEvAsyncOutputError : public NActors::TEventLocal<TEvAsyncOutputError, EvRuntimeError> { |
56 |
| - TEvAsyncOutputError(NYql::NDqProto::StatusIds::StatusCode statusCode, const TIssues& issues) |
57 |
| - : StatusCode(statusCode) |
58 |
| - , Issues(issues) |
59 |
| - {} |
60 |
| - |
61 |
| - NYql::NDqProto::StatusIds::StatusCode StatusCode; |
62 |
| - NYql::TIssues Issues; |
63 |
| - }; |
64 |
| -}; |
65 |
| - |
66 |
| -} // anonymous namespace |
67 |
| - |
68 | 45 | struct TSinkCallbacks : public IDqComputeActorAsyncOutput::ICallbacks {
|
69 | 46 | void OnAsyncOutputError(ui64 outputIndex, const TIssues& issues, NYql::NDqProto::StatusIds::StatusCode fatalCode) override final {
|
70 | 47 | OnSinkError(outputIndex, issues, fatalCode);
|
@@ -121,6 +98,26 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
|
121 | 98 | , public TSinkCallbacks
|
122 | 99 | , public TOutputTransformCallbacks
|
123 | 100 | {
|
| 101 | +private: |
| 102 | + struct TEvPrivate { |
| 103 | + enum EEv : ui32 { |
| 104 | + EvAsyncOutputError = EventSpaceBegin(NActors::TEvents::ES_PRIVATE), |
| 105 | + EvEnd |
| 106 | + }; |
| 107 | + |
| 108 | + static_assert(EvEnd < EventSpaceEnd(NActors::TEvents::ES_PRIVATE), "expect EvEnd < EventSpaceEnd(TEvents::ES_PRIVATE)"); |
| 109 | + |
| 110 | + struct TEvAsyncOutputError : public NActors::TEventLocal<TEvAsyncOutputError, EvAsyncOutputError> { |
| 111 | + TEvAsyncOutputError(NYql::NDqProto::StatusIds::StatusCode statusCode, const TIssues& issues) |
| 112 | + : StatusCode(statusCode) |
| 113 | + , Issues(issues) |
| 114 | + {} |
| 115 | + |
| 116 | + NYql::NDqProto::StatusIds::StatusCode StatusCode; |
| 117 | + NYql::TIssues Issues; |
| 118 | + }; |
| 119 | + }; |
| 120 | + |
124 | 121 | protected:
|
125 | 122 | enum EEvWakeupTag : ui64 {
|
126 | 123 | TimeoutTag = 1,
|
|
0 commit comments