diff --git a/src/batch-doctrine-dbal/src/DoctrineDBALJobExecutionStorage.php b/src/batch-doctrine-dbal/src/DoctrineDBALJobExecutionStorage.php index d4db908..0632180 100644 --- a/src/batch-doctrine-dbal/src/DoctrineDBALJobExecutionStorage.php +++ b/src/batch-doctrine-dbal/src/DoctrineDBALJobExecutionStorage.php @@ -8,6 +8,7 @@ use Doctrine\DBAL\Driver\Result; use Doctrine\DBAL\Exception as DBALException; use Doctrine\DBAL\Query\QueryBuilder; +use Doctrine\DBAL\Schema\AbstractAsset; use Doctrine\DBAL\Schema\Comparator; use Doctrine\DBAL\Schema\Schema; use Doctrine\DBAL\Types\Types; @@ -60,10 +61,13 @@ public function __construct(ConnectionRegistry $doctrine, array $options) */ public function setup(): void { - $assetFilter = $this->connection->getConfiguration()->getSchemaAssetsFilter(); - $this->connection->getConfiguration()->setSchemaAssetsFilter( - fn(string $tableName) => $tableName === $this->table, - ); + $assetFilter = $this->connection->getConfiguration()->getSchemaAssetsFilter() + ?? fn() => true; + $this->connection->getConfiguration()->setSchemaAssetsFilter(function (string|AbstractAsset $table) { + $table = $table instanceof AbstractAsset ? $table->getName() : $table; + + return $table === $this->table; + }); $schemaManager = \method_exists($this->connection, 'createSchemaManager') ? $this->connection->createSchemaManager() diff --git a/src/batch-symfony-messenger/src/MessengerJobsConfiguration.php b/src/batch-symfony-messenger/src/MessengerJobsConfiguration.php index 4f1ad0f..2d87d87 100644 --- a/src/batch-symfony-messenger/src/MessengerJobsConfiguration.php +++ b/src/batch-symfony-messenger/src/MessengerJobsConfiguration.php @@ -10,7 +10,9 @@ final class MessengerJobsConfiguration { public function __construct( - /** @var array */ + /** + * @var array + */ private array $routing, ) { }