Update

Author: ilyakharev

src/Retry/Retry.php

@@ -89,7 +89,7 @@ public function retry(Closure $closure, bool $idempotent)
                 }
                 $retryCount++;
                 $lastException = $e;
-                $delay = $this->retryDelay($retryCount, $this->backoffType($e))*1000; // in microseconds
+                $delay = $this->retryDelay($retryCount, $this->backoffType($e))*1000;
                 usleep($delay);
             }
         }

src/Table.php

@@ -483,8 +483,7 @@ public function retrySession(Closure $userFunc, bool $idempotent = false, RetryP
 
     public function retryTransaction(Closure $userFunc, bool $idempotent = false, RetryParams $params = null){
 
-        return $this->retry->withParams($params)->retry(function () use ($params, $idempotent, $userFunc){
-            $this->retrySession(function (Session $session) use ($userFunc) {
+        return $this->retrySession(function (Session $session) use ($userFunc) {
                 try{
                         $session->beginTransaction();
                         $result = $userFunc($session);
@@ -497,7 +496,6 @@ public function retryTransaction(Closure $userFunc, bool $idempotent = false, Re
                     throw $exception;
                 }
             }, $idempotent, $params);
-        }, $idempotent);
 
     }
 

src/Traits/RequestTrait.php

@@ -116,6 +116,8 @@ protected function doStreamRequest($service, $method, $data = [])
     {
         $this->checkDiscovery();
 
+        $this->meta['x-ydb-auth-ticket'] = [$this->credentials->token()];
+
         if (method_exists($this, 'take')) {
             $this->take();
         }
@@ -171,7 +173,7 @@ protected function handleGrpcStatus($service, $method, $status)
                 (isset(self::$grpcExceptions[$status->code])?self::$grpcNames[$status->code]:$status->code)
                 .' ' . $status->code . '): ' . ($status->details ?? 'no details');
             $this->logger->error($message);
-            if ($this->ydb->needDiscovery()&&get_class($this)!==Discovery::class){
+            if ($this->ydb->needDiscovery()){
                 try{
                     $this->ydb->discover();
                 }catch (\Exception $e){}