Fix typo in the method name in DataInconsistencyRepository

[MAILPOET-6213]
This commit is contained in:
Rostislav Wolny
2024-09-12 15:15:26 +02:00
committed by Aschepikov
parent 79f12dfeb4
commit 30520f08fa

View File

@@ -37,12 +37,12 @@ class DataInconsistencyRepository {
public function getOrphanedScheduledTasksSubscribersCount(): int { public function getOrphanedScheduledTasksSubscribersCount(): int {
$this->createOrphanedScheduledTaskSubscribersTemporaryTables(); $this->createOrphanedScheduledTaskSubscribersTemporaryTables();
$count = $this->getOrphanedScheduledTasksSubscribersCountFromTemplateTables(); $count = $this->getOrphanedScheduledTasksSubscribersCountFromTemporaryTables();
$this->dropOrphanedScheduledTaskSubscribersTemporaryTables(); $this->dropOrphanedScheduledTaskSubscribersTemporaryTables();
return $count; return $count;
} }
private function getOrphanedScheduledTasksSubscribersCountFromTemplateTables(): int { private function getOrphanedScheduledTasksSubscribersCountFromTemporaryTables(): int {
$connection = $this->entityManager->getConnection(); $connection = $this->entityManager->getConnection();
$stsTable = $this->entityManager->getClassMetadata(ScheduledTaskSubscriberEntity::class)->getTableName(); $stsTable = $this->entityManager->getClassMetadata(ScheduledTaskSubscriberEntity::class)->getTableName();
/** @var string $count */ /** @var string $count */
@@ -166,7 +166,7 @@ class DataInconsistencyRepository {
['limit' => self::DELETE_ROWS_LIMIT], ['limit' => self::DELETE_ROWS_LIMIT],
['limit' => ParameterType::INTEGER] ['limit' => ParameterType::INTEGER]
); );
} while ($this->getOrphanedScheduledTasksSubscribersCountFromTemplateTables() > 0); } while ($this->getOrphanedScheduledTasksSubscribersCountFromTemporaryTables() > 0);
$this->dropOrphanedScheduledTaskSubscribersTemporaryTables(); $this->dropOrphanedScheduledTaskSubscribersTemporaryTables();
return $deletedCount; return $deletedCount;
} }