@@ -53,6 +53,7 @@ func lookupYdbOperationStatus(
5353 )
5454 opResponse , err := client .GetOperationStatus (ctx , conn , ydbOperationId )
5555 if err != nil {
56+ xlog .Error (ctx , "GetOperationStatus error" , zap .Error (err ))
5657 if deadlineExceeded (createdAt , config ) {
5758 return & LookupYdbOperationResponse {
5859 shouldAbortHandler : true ,
@@ -78,6 +79,13 @@ func lookupYdbOperationStatus(
7879 }
7980
8081 if ! isValidStatus (opResponse .GetOperation ().GetStatus ()) {
82+ xlog .Info (
83+ ctx , "received error status" ,
84+ zap .String ("id" , operation .GetID ()),
85+ zap .String ("type" , string (operation .GetType ())),
86+ zap .String ("ydb_operation_id" , ydbOperationId ),
87+ zap .String ("operation_status" , string (opResponse .GetOperation ().GetStatus ())),
88+ )
8189 return & LookupYdbOperationResponse {
8290 opResponse : opResponse ,
8391 shouldAbortHandler : true ,
@@ -90,6 +98,12 @@ func lookupYdbOperationStatus(
9098 }, nil
9199 }
92100
101+ xlog .Info (ctx , "got operation status from server" ,
102+ zap .String ("id" , operation .GetID ()),
103+ zap .String ("type" , string (operation .GetType ())),
104+ zap .String ("ydb_operation_id" , ydbOperationId ),
105+ zap .String ("operation_status" , string (opResponse .GetOperation ().GetStatus ())),
106+ )
93107 return & LookupYdbOperationResponse {
94108 opResponse : opResponse ,
95109 }, nil
0 commit comments