@@ -480,7 +480,6 @@ class TSchedulerActor : public TActorBootstrapped<TSchedulerActor> {
480480 }
481481 Opts.Scheduler ->SetForgetInterval (Opts.ForgetOverflowTimeout );
482482 Opts.Scheduler ->ReportCounters (Opts.Counters );
483- SetCapacity ();
484483 }
485484
486485 void Bootstrap () {
@@ -491,13 +490,14 @@ class TSchedulerActor : public TActorBootstrapped<TSchedulerActor> {
491490 new NConsole::TEvConfigsDispatcher::TEvSetConfigSubscriptionRequest ({tableServiceConfigKind}),
492491 IEventHandle::FlagTrackDelivery);
493492
493+ SetCapacity (SelfId ().PoolID ());
494494 Become (&TSchedulerActor::State);
495495 }
496496
497- void SetCapacity () {
497+ void SetCapacity (ui32 poolId ) {
498498 NActors::TExecutorPoolStats poolStats;
499499 TVector<NActors::TExecutorThreadStats> threadsStats;
500- TlsActivationContext->ActorSystem ()->GetPoolStats (SelfId (). PoolID () , poolStats, threadsStats);
500+ TlsActivationContext->ActorSystem ()->GetPoolStats (poolId , poolStats, threadsStats);
501501 Y_ENSURE (poolStats.MaxThreadCount > 0 );
502502 Opts.Counters ->SchedulerCapacity ->Set (poolStats.MaxThreadCount );
503503 Opts.Scheduler ->SetCapacity (poolStats.MaxThreadCount );
@@ -550,7 +550,7 @@ class TSchedulerActor : public TActorBootstrapped<TSchedulerActor> {
550550 }
551551
552552 void Handle (TEvents::TEvWakeup::TPtr&) {
553- SetCapacity ();
553+ SetCapacity (SelfId (). PoolID () );
554554 Opts.Scheduler ->AdvanceTime (TlsActivationContext->Monotonic ());
555555 Schedule (Opts.AdvanceTimeInterval , new TEvents::TEvWakeup ());
556556 }
0 commit comments