Skip to content

Commit 98da290

Browse files
committed
Fix parallel running initializing with empty redis
1 parent 92cd0e2 commit 98da290

File tree

2 files changed

+15
-1
lines changed

2 files changed

+15
-1
lines changed

src/DB/RedisConnection.php

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,11 @@ public function __construct(RedisConfigAccessor $redisConfigAccessor)
1919
$this->redisConfig = $redisConfigAccessor->getRedisConfig();
2020
}
2121

22+
public function isReady()
23+
{
24+
return $this->redisConfig !== null;
25+
}
26+
2227
public function getConnection()
2328
{
2429
if (isset(self::$connection)) {

src/Services/ExperimentsParallelRun/ParallelRunInitializer.php

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55
namespace Abrouter\Client\Services\ExperimentsParallelRun;
66

77
use Abrouter\Client\DB\Managers\ParallelRunningStateManager;
8+
use Abrouter\Client\DB\RedisConnection;
89
use Abrouter\Client\DB\RelatedUsersStore;
910
use Abrouter\Client\DB\Repositories\ParallelRunningStateCachedRepository;
1011

@@ -14,16 +15,24 @@ class ParallelRunInitializer
1415

1516
private ParallelRunningStateManager $parallelRunningStateManager;
1617

18+
private RedisConnection $redisConnection;
19+
1720
public function __construct(
1821
ParallelRunningStateCachedRepository $parallelRunningStateCachedRepository,
19-
ParallelRunningStateManager $parallelRunningStateManager
22+
ParallelRunningStateManager $parallelRunningStateManager,
23+
RedisConnection $redisConnection
2024
) {
2125
$this->parallelRunningStateCachedRepository = $parallelRunningStateCachedRepository;
2226
$this->parallelRunningStateManager = $parallelRunningStateManager;
27+
$this->redisConnection = $redisConnection;
2328
}
2429

2530
public function initializeIfNot(): bool
2631
{
32+
if (!$this->redisConnection->isReady()) {
33+
return false;
34+
}
35+
2736
//if parallel running ready to serve
2837
if ($this->parallelRunningStateCachedRepository->isReady()) {
2938
return true;

0 commit comments

Comments
 (0)