ReconnectPeriod has been fixed for pq_read_actor (#13921) (#13941)

dorooleg · web-flow · commit 65fb266d2542 · 2025-01-30T13:08:31.000+03:00
diff --git a/ydb/library/yql/providers/pq/async_io/dq_pq_read_actor.cpp b/ydb/library/yql/providers/pq/async_io/dq_pq_read_actor.cpp
@@ -288,7 +288,7 @@ class TDqPqReadActor : public NActors::TActor<TDqPqReadActor>, public NYql::NDq:
 
         if (!InflightReconnect && ReconnectPeriod != TDuration::Zero()) {
             Metrics.ReconnectRate->Inc();
-            Schedule(ReconnectPeriod, new TEvPrivate::TEvSourceDataReady());
+            Schedule(ReconnectPeriod, new TEvPrivate::TEvReconnectSession());
             InflightReconnect = true;
         }
 

Original file line number	Diff line number	Diff line change
`@@ -288,7 +288,7 @@ class TDqPqReadActor : public NActors::TActor<TDqPqReadActor>, public NYql::NDq:`
`288`	`288`
`289`	`289`	`if (!InflightReconnect && ReconnectPeriod != TDuration::Zero()) {`
`290`	`290`	`Metrics.ReconnectRate->Inc();`
`291`		`- Schedule(ReconnectPeriod, new TEvPrivate::TEvSourceDataReady());`
	`291`	`+ Schedule(ReconnectPeriod, new TEvPrivate::TEvReconnectSession());`
`292`	`292`	`InflightReconnect = true;`
`293`	`293`	`}`
`294`	`294`