SchedulerBundle #1739

    protected function handleOperationViaFiber(Closure $func): mixed
    {
        $fiber = new Fiber(callback: function (Closure $operation): void {
            $value = $operation();
            Fiber::suspend(value: $value);
Call to static method suspend() on an unknown class Fiber.
Time to fix: about 9 minutes
Read doc
                Open Issue
             Permalink

                                    Last edited Thu, 28 Apr 2022 10:52:11 +0000 by Guillaume Loulier
                    
        });
        try {
            $return = $fiber->start($func);
        } catch (Throwable $throwable) {

        $this->logger = $logger ?? new NullLogger();
    }
    protected function handleOperationViaFiber(Closure $func): mixed
    {
        $fiber = new Fiber(callback: function (Closure $operation): void {
Instantiated class Fiber not found.
Time to fix: about 1 hour
Read doc
                Open Issue
             Permalink

                                    Last edited Thu, 28 Apr 2022 10:52:11 +0000 by Guillaume Loulier
                    
            $value = $operation();
            Fiber::suspend(value: $value);
        });

        return $serializer;
    }
    abstract protected function buildConnection(): Connection;
    public function testConnectionCanListEmptyTasks(): void
The next 21 lines appear both in tests/Bridge/Doctrine/Transport/AbstractConnectionIntegrationTest.php:87 and tests/Bridge/Doctrine/Transport/ConnectionIntegrationTest.php:104.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $list = $this->connection->list();
        self::assertCount(0, $list);
    }

    public function testConnectionCanRetrieveASingleTask(): void
    {
        $this->connection->setup();
        $this->connection->create(task: new NullTask(name: 'foo'));
        $task = $this->connection->get(taskName: 'foo');
The next 27 lines appear both in tests/Bridge/Doctrine/Transport/AbstractConnectionIntegrationTest.php:165 and tests/Bridge/Doctrine/Transport/ConnectionIntegrationTest.php:182.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Sun, 19 Jun 2022 15:01:00 +0000 by Guillaume Loulier
                    
        self::assertInstanceOf(NullTask::class, $task);
        self::assertSame('foo', $task->getName());
        self::assertSame('* * * * *', $task->getExpression());
    }

    public function testMessengerTaskCanBeCreated(): void
    {
        $this->connection->setup();
        $this->connection->create(task: new MessengerTask(name: 'foo', message: new MessengerMessage()));
        $task = $this->connection->get(taskName: 'foo');
The next 110 lines appear both in tests/Bridge/Doctrine/Transport/AbstractConnectionIntegrationTest.php:223 and tests/Bridge/Doctrine/Transport/ConnectionIntegrationTest.php:240.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Sun, 19 Jun 2022 15:01:00 +0000 by Guillaume Loulier
                    
        self::assertInstanceOf(MessengerTask::class, $task);
        self::assertInstanceOf(MessengerMessage::class, $task->getMessage());
        self::assertSame('foo', $task->getName());
        self::assertSame('* * * * *', $task->getExpression());

    }
    /**
     * @throws Exception {@see Connection::setup()}
     */
    public function testTaskCanBePaused(): void
The next 19 lines appear both in tests/Bridge/Doctrine/Transport/AbstractConnectionIntegrationTest.php:279 and tests/Bridge/Doctrine/Transport/ConnectionIntegrationTest.php:369.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $this->connection->setup();
        $this->connection->create(new NullTask('foo'));
        $task = $this->connection->get('foo');

    }
    /**
     * @throws Exception {@see Connection::setup()}
     */
    public function testTaskCanBePaused(): void
The next 17 lines appear both in tests/Bridge/Doctrine/Transport/AbstractConnectionIntegrationTest.php:279 and tests/Bridge/Doctrine/Transport/ConnectionIntegrationTest.php:340.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $this->connection->setup();
        $this->connection->create(new NullTask('foo'));
        $task = $this->connection->get('foo');

    }
    /**
     * @throws Exception {@see Connection::setup()}
     */
    public function testTaskCanBeEnabled(): void
The next 20 lines appear both in tests/Bridge/Doctrine/Transport/AbstractConnectionIntegrationTest.php:323 and tests/Bridge/Doctrine/Transport/AbstractConnectionIntegrationTest.php:353.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $this->connection->setup();
        $this->connection->create(new NullTask('foo'));
        $task = $this->connection->get('foo');

        self::assertInstanceOf(NullTask::class, $task);
        self::assertSame('foo', $task->getName());
        self::assertSame('* * * * *', $task->getExpression());
        self::assertSame(TaskInterface::ENABLED, $task->getState());
        $this->connection->pause('foo');
The next 28 lines appear both in tests/Bridge/Doctrine/Transport/AbstractConnectionIntegrationTest.php:335 and tests/Bridge/Doctrine/Transport/ConnectionIntegrationTest.php:351.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
        $task = $this->connection->get('foo');
        self::assertInstanceOf(NullTask::class, $task);
        self::assertSame(TaskInterface::PAUSED, $task->getState());

        self::assertInstanceOf(NullTask::class, $task);
        self::assertSame('foo', $task->getName());
        self::assertSame('* * * * *', $task->getExpression());
        self::assertSame(TaskInterface::ENABLED, $task->getState());
        $this->connection->pause('foo');
The next 53 lines appear both in tests/Bridge/Doctrine/Transport/AbstractConnectionIntegrationTest.php:365 and tests/Bridge/Doctrine/Transport/ConnectionIntegrationTest.php:380.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
        $task = $this->connection->get('foo');
        self::assertInstanceOf(NullTask::class, $task);
        self::assertSame(TaskInterface::PAUSED, $task->getState());

/**
 * @author Guillaume Loulier <contact@guillaumeloulier.fr>
 */
final class ConnectionTest extends TestCase
{
    public function testConnectionCanReturnATaskList(): void
The next 19 lines appear both in tests/Bridge/Doctrine/Transport/ConnectionTest.php:42 and tests/Bridge/Doctrine/Transport/ConnectionTest.php:91.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $serializer = $this->createMock(SerializerInterface::class);
        $queryBuilder = $this->getQueryBuilderMock();
        $queryBuilder->expects(self::exactly(2))->method('select')

        ;
        $queryBuilder->expects(self::once())->method('getSQL')->willReturn('SELECT * FROM _symfony_scheduler_tasks');
        $queryBuilder->expects(self::once())->method('getParameters')->willReturn([]);
        $queryBuilder->expects(self::once())->method('getParameterTypes')->willReturn([]);
        $statement = $this->createMock(class_exists(NextResult::class) ? NextResult::class : Result::class);
The next 20 lines appear both in tests/Bridge/Doctrine/Transport/ConnectionTest.php:108 and tests/Bridge/Doctrine/Transport/ConnectionTest.php:165.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Fri, 03 Dec 2021 16:20:08 +0000 by Guillaume Loulier
                    
        $statement->expects(self::once())->method('fetchOne')->willReturn('0');
        $driverConnection = $this->getDBALConnectionMock();
        $driverConnection->expects(self::once())->method('createQueryBuilder')->willReturn($queryBuilder);
        $driverConnection->expects(self::once())->method('executeQuery')->willReturn($statement);

        ]));
        self::assertEmpty($connection->list());
    }
    public function testConnectionCannotReturnAnInvalidTask(): void
The next 17 lines appear both in tests/Bridge/Doctrine/Transport/ConnectionTest.php:130 and tests/Bridge/Doctrine/Transport/ConnectionTest.php:190.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $serializer = $this->createMock(SerializerInterface::class);
        $expressionBuilder = $this->createMock(ExpressionBuilder::class);
        $expressionBuilder->expects(self::once())->method('eq')

    public function testConnectionCannotReturnAnInvalidTask(): void
    {
        $serializer = $this->createMock(SerializerInterface::class);
        $expressionBuilder = $this->createMock(ExpressionBuilder::class);
The next 14 lines appear both in tests/Bridge/Doctrine/Transport/ConnectionTest.php:134 and tests/Bridge/Doctrine/Transport/ConnectionTest.php:497.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 06 Apr 2021 04:38:32 +0000 by Guillaume Loulier
                    
        $expressionBuilder->expects(self::once())->method('eq')
            ->with(self::equalTo('t.task_name'), self::equalTo(':name'))
            ->willReturn('t.task_name = :name')
        ;

    public function testConnectionCannotReturnAnInvalidTask(): void
    {
        $serializer = $this->createMock(SerializerInterface::class);
        $expressionBuilder = $this->createMock(ExpressionBuilder::class);
The next 20 lines appear both in tests/Bridge/Doctrine/Transport/ConnectionTest.php:134 and tests/Bridge/Doctrine/Transport/ConnectionTest.php:321.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 06 Apr 2021 04:38:32 +0000 by Guillaume Loulier
                    
        $expressionBuilder->expects(self::once())->method('eq')
            ->with(self::equalTo('t.task_name'), self::equalTo(':name'))
            ->willReturn('t.task_name = :name')
        ;

        $queryBuilder->expects(self::once())->method('setParameter')->with(
            self::equalTo('name'),
            self::equalTo('foo'),
            self::equalTo(ParameterType::STRING)
        );
        $queryBuilder->expects(self::once())->method('getSQL')
The next 15 lines appear both in tests/Bridge/Doctrine/Transport/ConnectionTest.php:155 and tests/Bridge/Doctrine/Transport/ConnectionTest.php:563.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 06 Apr 2021 04:38:32 +0000 by Guillaume Loulier
                    
            ->willReturn('SELECT * FROM _symfony_scheduler_tasks WHERE task_name = :name')
        ;
        $queryBuilder->expects(self::once())->method('getParameters')
            ->willReturn(['name' => 'foo'])
        ;

            self::equalTo(ParameterType::STRING)
        );
        $queryBuilder->expects(self::once())->method('getSQL')
            ->willReturn('SELECT * FROM _symfony_scheduler_tasks WHERE task_name = :name')
        ;
        $queryBuilder->expects(self::once())->method('getParameters')
The next 14 lines appear both in tests/Bridge/Doctrine/Transport/ConnectionTest.php:158 and tests/Bridge/Doctrine/Transport/ConnectionTest.php:345.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 06 Apr 2021 04:38:32 +0000 by Guillaume Loulier
                    
            ->willReturn(['name' => 'foo'])
        ;
        $queryBuilder->expects(self::once())->method('getParameterTypes')
            ->willReturn(['name' => ParameterType::STRING])
        ;

            ->with(self::equalTo('t.task_name'), self::equalTo(':name'))
            ->willReturn('t.task_name = :name')
        ;
        $queryBuilder = $this->getQueryBuilderMock();
        $queryBuilder->expects(self::once())->method('expr')->willReturn($expressionBuilder);
The next 34 lines appear both in tests/Bridge/Doctrine/Transport/ConnectionTest.php:201 and tests/Bridge/Doctrine/Transport/DoctrineTransportTest.php:239.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 06 Apr 2021 04:38:32 +0000 by Guillaume Loulier
                    
        $queryBuilder->expects(self::exactly(2))->method('select')
            ->withConsecutive([self::equalTo('t.*')], [self::equalTo('COUNT(DISTINCT t.id)')])
            ->willReturnSelf()
        ;
        $queryBuilder->expects(self::once())->method('from')

            ->willReturn('t.task_name = :name')
        ;
        $queryBuilder = $this->getQueryBuilderMock();
        $queryBuilder->expects(self::once())->method('expr')->willReturn($expressionBuilder);
        $queryBuilder->expects(self::exactly(2))->method('select')
The next 18 lines appear both in tests/Bridge/Doctrine/Transport/ConnectionTest.php:202 and tests/Bridge/Doctrine/Transport/DoctrineTransportTest.php:382.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 06 Apr 2021 04:38:32 +0000 by Guillaume Loulier
                    
            ->withConsecutive([self::equalTo('t.*')], [self::equalTo('COUNT(DISTINCT t.id)')])
            ->willReturnSelf()
        ;
        $queryBuilder->expects(self::once())->method('from')
            ->with(self::equalTo('_symfony_scheduler_tasks'), self::equalTo('t'))

        $queryBuilder->expects(self::once())->method('setParameter')->with(
            self::equalTo('name'),
            self::equalTo('foo'),
            self::equalTo(ParameterType::STRING)
        )->willReturnSelf();
        $queryBuilder->expects(self::once())->method('getSQL')
The next 16 lines appear both in tests/Bridge/Doctrine/Transport/ConnectionTest.php:219 and tests/Bridge/Doctrine/Transport/ConnectionTest.php:515.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 06 Apr 2021 04:38:32 +0000 by Guillaume Loulier
                    
            ->willReturn('SELECT * FROM _symfony_scheduler_tasks WHERE task_name = :name')
        ;
        $queryBuilder->expects(self::once())->method('getParameters')
            ->willReturn(['name' => 'foo'])
        ;

    public function testConnectionCannotInsertASingleTaskWithDuplicatedIdentifier(): void
    {
        $serializer = $this->createMock(SerializerInterface::class);
        $task = new NullTask('foo');
The next 40 lines appear both in tests/Bridge/Doctrine/Transport/ConnectionTest.php:319 and tests/Bridge/Doctrine/Transport/ConnectionTest.php:384.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Thu, 23 Jun 2022 03:23:01 +0000 by Jérémy
                    
        $expressionBuilder = $this->createMock(ExpressionBuilder::class);
        $expressionBuilder->expects(self::once())->method('eq')
            ->with(self::equalTo('t.task_name'), self::equalTo(':name'))
            ->willReturn('t.task_name = :name')

            new FirstInFirstOutPolicy(),
        ]));
        $connection->create($task);
    }
    public function testConnectionCannotPauseATaskWithInvalidIdentifier(): void
The next 17 lines appear both in tests/Bridge/Doctrine/Transport/ConnectionTest.php:437 and tests/Bridge/Doctrine/Transport/ConnectionTest.php:545.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $serializer = $this->createMock(SerializerInterface::class);
        $expressionBuilder = $this->createMock(ExpressionBuilder::class);
        $expressionBuilder->expects(self::once())->method('eq')

            ->willReturn('SELECT * FROM _symfony_scheduler_tasks WHERE task_name = :name')
        ;
        $queryBuilder->expects(self::once())->method('getParameters')
            ->willReturn(['name' => 'bar'])
        ;
        $queryBuilder->expects(self::once())->method('getParameterTypes')
The next 24 lines appear both in tests/Bridge/Doctrine/Transport/ConnectionTest.php:461 and tests/Bridge/Doctrine/Transport/ConnectionTest.php:569.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 06 Apr 2021 04:38:32 +0000 by Guillaume Loulier
                    
            ->willReturn(['name' => ParameterType::STRING])
        ;
        $statement = $this->createMock(class_exists(NextResult::class) ? NextResult::class : Result::class);
        $statement->expects(self::once())->method('fetchOne')->willReturn('0');

    }
    public function testConnectionCanPauseASingleTask(): void
    {
        $task = $this->createMock(TaskInterface::class);
        $task->expects(self::once())->method('setState')->with(self::equalTo(TaskInterface::PAUSED));
The next 39 lines appear both in tests/Bridge/Doctrine/Transport/ConnectionTest.php:492 and tests/Bridge/Doctrine/Transport/ConnectionTest.php:600.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 06 Apr 2021 04:38:32 +0000 by Guillaume Loulier
                    
        $serializer = $this->createMock(SerializerInterface::class);
        $serializer->expects(self::never())->method('serialize');
        $expressionBuilder = $this->createMock(ExpressionBuilder::class);

        $queryBuilder->expects(self::once())->method('expr')->willReturn($expressionBuilder);
        $queryBuilder->expects(self::exactly(2))->method('select')
            ->withConsecutive([self::equalTo('t.*')], [self::equalTo('COUNT(DISTINCT t.id)')])
            ->willReturnSelf()
        ;
        $queryBuilder->expects(self::once())->method('where')
The next 18 lines appear both in tests/Bridge/Doctrine/Transport/ConnectionTest.php:509 and tests/Bridge/Doctrine/Transport/ConnectionTest.php:557.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 06 Apr 2021 04:38:32 +0000 by Guillaume Loulier
                    
            ->with(self::equalTo('t.task_name = :name'))
        ;
        $queryBuilder->expects(self::once())->method('setParameter')
            ->with(self::equalTo('name'), self::equalTo('foo'))
        ;

     */
    private function getDBALConnectionMock()
    {
        $platform = $this->createMock(AbstractPlatform::class);
        $platform->method('getWriteLockSQL')->willReturn('FOR UPDATE');
        $platform->method('getReadLockSQL')->willReturn('FOR UPDATE');
The next 18 lines appear both in tests/Bridge/Doctrine/Transport/ConnectionTest.php:875 and tests/Bridge/Doctrine/Transport/DoctrineTransportTest.php:740.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Thu, 11 Feb 2021 14:43:10 +0000 by Guillaume Loulier
                    
        $configuration = $this->createMock(Configuration::class);
        $driverConnection = $this->createMock(Connection::class);
        $driverConnection->method('getDatabasePlatform')->willReturn($platform);

    /**
     * @throws JsonException
     * @throws Throwable     {@see TransportInterface::list()}
     */
    public function testTransportCanListTasks(): void
The next 41 lines appear both in tests/Bridge/Doctrine/Transport/DoctrineTransportTest.php:132 and tests/Bridge/Doctrine/Transport/DoctrineTransportTest.php:181.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $serializer = $this->createMock(SerializerInterface::class);
        $queryBuilder = $this->createMock(QueryBuilder::class);
        $queryBuilder->expects(self::exactly(2))->method('select')

        self::assertInstanceOf(LazyTaskList::class, $list);
        self::assertCount(0, $list);
    }
    public function testTransportCanGetATask(): void
The next 62 lines appear both in tests/Bridge/Doctrine/Transport/DoctrineTransportTest.php:227 and tests/Bridge/Doctrine/Transport/DoctrineTransportTest.php:294.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $task = $this->createMock(TaskInterface::class);
        $serializer = $this->createMock(SerializerInterface::class);
        $expressionBuilder = $this->createMock(ExpressionBuilder::class);

    }
    public function testTransportCanGetATask(): void
    {
        $task = $this->createMock(TaskInterface::class);
        $serializer = $this->createMock(SerializerInterface::class);
The next 62 lines appear both in tests/Bridge/Doctrine/Transport/DoctrineTransportTest.php:230 and tests/Bridge/Doctrine/Transport/DoctrineTransportTest.php:609.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
        $expressionBuilder = $this->createMock(ExpressionBuilder::class);
        $expressionBuilder->expects(self::once())->method('eq')
            ->with(self::equalTo('t.task_name'), self::equalTo(':name'))
            ->willReturn('t.task_name = :name')

    }
    public function testTransportCanGetATask(): void
    {
        $task = $this->createMock(TaskInterface::class);
        $serializer = $this->createMock(SerializerInterface::class);
The next 46 lines appear both in tests/Bridge/Doctrine/Transport/DoctrineTransportTest.php:230 and tests/Bridge/Doctrine/Transport/DoctrineTransportTest.php:534.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
        $expressionBuilder = $this->createMock(ExpressionBuilder::class);
        $expressionBuilder->expects(self::once())->method('eq')
            ->with(self::equalTo('t.task_name'), self::equalTo(':name'))
            ->willReturn('t.task_name = :name')

    public function testTransportCannotCreateAnExistingTask(): void
    {
        $serializer = $this->createMock(SerializerInterface::class);
        $task = new NullTask('foo');
The next 42 lines appear both in tests/Bridge/Doctrine/Transport/DoctrineTransportTest.php:372 and tests/Bridge/Doctrine/Transport/DoctrineTransportTest.php:442.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Thu, 23 Jun 2022 03:23:01 +0000 by Jérémy
                    
        $expression = $this->createMock(ExpressionBuilder::class);
        $expression->expects(self::once())->method('eq')
            ->with(self::equalTo('t.task_name'), self::equalTo(':name'))
            ->willReturn('t.task_name = :name')

            ), $objectNormalizer,
        ], [new JsonEncoder()]);
        $objectNormalizer->setSerializer($serializer);
        try {
            $this->connection = new Connection(new InMemoryConfiguration([
The next 22 lines appear both in tests/Bridge/Redis/Transport/ConnectionIntegrationTest.php:71 and tests/Bridge/Redis/Transport/RedisTransportIntegrationTest.php:74.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 26 Apr 2022 07:44:31 +0000 by Guillaume Loulier
                    
                'host' => $dsn->getHost(),
                'password' => $dsn->getPassword(),
                'port' => $dsn->getPort(),
                'scheme' => $dsn->getScheme(),
                'timeout' => $dsn->getOption('timeout', 30),

        self::expectExceptionMessage('The list is not initialized');
        self::expectExceptionCode(0);
        $connection->list();
    }
    public function testConnectionCanConnectWithoutSpecificPort(): void
The next 31 lines appear both in tests/Bridge/Redis/Transport/ConnectionTest.php:140 and tests/Bridge/Redis/Transport/ConnectionTest.php:170.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Mon, 06 Sep 2021 06:01:51 +0000 by Guillaume Loulier
                    
    {
        $serializer = $this->createMock(SerializerInterface::class);
        $redis = $this->createMock(Redis::class);
        $redis->expects(self::once())->method('connect')->with(

        $connection->create($taskToCreate);
    }
    public function testConnectionCannotGetUndefinedTask(): void
    {
        $serializer = $this->createMock(SerializerInterface::class);
The next 26 lines appear both in tests/Bridge/Redis/Transport/ConnectionTest.php:349 and tests/Bridge/Redis/Transport/ConnectionTest.php:383.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
        $redis = $this->createMock(Redis::class);
        $redis->expects(self::once())->method('connect');
        $redis->expects(self::once())->method('select')->with(self::equalTo(0))->willReturn(true);
        $redis->expects(self::once())->method('auth')->willReturn(true);

    {
        $serializer = $this->createMock(SerializerInterface::class);
        $redis = $this->createMock(Redis::class);
        $redis->expects(self::once())->method('connect');
        $redis->expects(self::once())->method('select')->with(self::equalTo(0))->willReturn(true);
The next 24 lines appear both in tests/Bridge/Redis/Transport/ConnectionTest.php:353 and tests/Bridge/Redis/Transport/ConnectionTest.php:487.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Mon, 01 Mar 2021 06:39:02 +0000 by Guillaume Loulier
                    
        $redis->expects(self::once())->method('auth')->willReturn(true);
        $redis->expects(self::once())->method('hExists')->willReturn(false);
        $connection = new Connection(new InMemoryConfiguration([
            'host' => 'localhost',

        self::expectExceptionMessage('The task "foo" cannot be updated as it does not exist');
        self::expectExceptionCode(0);
        $connection->update('foo', $task);
    }
    public function testConnectionCannotUpdateWithError(): void
The next 13 lines appear both in tests/Bridge/Redis/Transport/ConnectionTest.php:413 and tests/Bridge/Redis/Transport/ConnectionTest.php:450.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $serializer = $this->createMock(SerializerInterface::class);
        $serializer->expects(self::once())->method('serialize')->willReturn('foo');
        $task = $this->createMock(TaskInterface::class);

        $redis = $this->createMock(Redis::class);
        $redis->expects(self::once())->method('connect');
        $redis->expects(self::once())->method('select')->with(self::equalTo(0))->willReturn(true);
        $redis->expects(self::once())->method('auth')->willReturn(true);
        $redis->expects(self::once())->method('hExists')->willReturn(true);
        $redis->expects(self::once())->method('hSet')->willReturn(false);
The next 21 lines appear both in tests/Bridge/Redis/Transport/ConnectionTest.php:425 and tests/Bridge/Redis/Transport/ConnectionTest.php:706.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
        $redis->expects(self::once())->method('getLastError')->willReturn('Random error');
        $connection = new Connection(new InMemoryConfiguration([
            'host' => 'localhost',
            'timeout' => 30,

        $serializer = $this->createMock(SerializerInterface::class);
        $serializer->expects(self::once())->method('deserialize')->willReturn($task);
        $redis = $this->createMock(Redis::class);
        $redis->expects(self::once())->method('select')->with(self::equalTo(0))->willReturn(true);
        $redis->expects(self::once())->method('auth')->willReturn(true);
The next 22 lines appear both in tests/Bridge/Redis/Transport/ConnectionTest.php:523 and tests/Bridge/Redis/Transport/ConnectionTest.php:665.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
        $redis->expects(self::once())->method('hExists')->willReturn(true);
        $redis->expects(self::once())->method('hGet');
        $connection = new Connection(new InMemoryConfiguration([
            'host' => 'localhost',

        self::expectExceptionMessage('The task "foo" is already paused');
        self::expectExceptionCode(0);
        $connection->pause('foo');
    }
    public function testConnectionCannotPauseWithUpdateException(): void
The next 16 lines appear both in tests/Bridge/Redis/Transport/ConnectionTest.php:549 and tests/Bridge/Redis/Transport/ConnectionTest.php:588.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $task = $this->createMock(TaskInterface::class);
        $task->expects(self::once())->method('getState')->willReturn(TaskInterface::ENABLED);
        $task->expects(self::once())->method('setState')->with(self::equalTo(TaskInterface::PAUSED))->willReturnSelf();

        $task->expects(self::once())->method('getState')->willReturn(TaskInterface::ENABLED);
        $task->expects(self::once())->method('setState')->with(self::equalTo(TaskInterface::PAUSED))->willReturnSelf();
        $serializer = $this->createMock(SerializerInterface::class);
        $serializer->expects(self::once())->method('deserialize')->willReturn($task);
        $serializer->expects(self::once())->method('serialize')->with($task, 'json')->willReturn('foo');
The next 8 lines appear both in tests/Bridge/Redis/Transport/ConnectionTest.php:557 and tests/Bridge/Redis/Transport/ConnectionTest.php:699.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
        $redis = $this->createMock(Redis::class);
        $redis->expects(self::once())->method('auth')->willReturn(true);
        $redis->expects(self::once())->method('select')->with(self::equalTo(0))->willReturn(true);
        $redis->expects(self::exactly(2))->method('hExists')->willReturn(true);

        self::expectExceptionMessage('The task "foo" is already enabled');
        self::expectExceptionCode(0);
        $connection->resume('foo');
    }
    public function testConnectionCannotResumeTaskWithUpdateException(): void
The next 16 lines appear both in tests/Bridge/Redis/Transport/ConnectionTest.php:691 and tests/Bridge/Redis/Transport/ConnectionTest.php:731.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $task = $this->createMock(TaskInterface::class);
        $task->expects(self::once())->method('getState')->willReturn(TaskInterface::PAUSED);
        $task->expects(self::once())->method('setState')->with(self::equalTo(TaskInterface::ENABLED))->willReturnSelf();

    }
    /**
     * @dataProvider provideList
     */
    public function testConnectionCannotEmptyWithException(string $list): void
The next 9 lines appear both in tests/Bridge/Redis/Transport/ConnectionTest.php:833 and tests/Bridge/Redis/Transport/ConnectionTest.php:868.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $serializer = $this->createMock(SerializerInterface::class);
        $redis = $this->createMock(Redis::class);
        $redis->expects(self::once())->method('auth')->willReturn(true);

    public function testCommandCannotDisplayTaskOutputWithoutVeryVerbose(): void
    {
        $eventDispatcher = new EventDispatcher();
        $task = new NullTask('foo', [
            'execution_memory_usage' => 9_507_552,
The next 22 lines appear both in tests/Command/ConsumeTasksCommandTest.php:430 and tests/Command/ConsumeTasksCommandTest.php:561.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Fri, 13 Aug 2021 06:40:49 +0000 by Guillaume Loulier
                    
        ]);
        $scheduler = $this->createMock(SchedulerInterface::class);
        $scheduler->expects(self::exactly(2))->method('getDueTasks')->willReturn(new TaskList([$task]));

        $task = new NullTask('foo', [
            'execution_memory_usage' => 9_507_552,
        ]);
        $scheduler = $this->createMock(SchedulerInterface::class);
The next 14 lines appear both in tests/Command/ConsumeTasksCommandTest.php:433 and tests/Command/ConsumeTasksCommandTest.php:477.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 06 Apr 2021 07:35:14 +0000 by Guillaume Loulier
                    
        $scheduler->expects(self::exactly(2))->method('getDueTasks')->willReturn(new TaskList([$task]));
        $tracker = $this->createMock(TaskExecutionTrackerInterface::class);
        $runner = $this->createMock(RunnerInterface::class);

        $task = new NullTask('foo', [
            'execution_memory_usage' => 9_507_552,
        ]);
        $scheduler = $this->createMock(SchedulerInterface::class);
The next 25 lines appear both in tests/Command/ConsumeTasksCommandTest.php:433 and tests/Command/ConsumeTasksCommandTest.php:520.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 06 Apr 2021 07:35:14 +0000 by Guillaume Loulier
                    
        $scheduler->expects(self::exactly(2))->method('getDueTasks')->willReturn(new TaskList([$task]));
        $tracker = $this->createMock(TaskExecutionTrackerInterface::class);
        $runner = $this->createMock(RunnerInterface::class);

    }
    /**
     * @throws Throwable
     */
    public function testCommandCanExecuteDueTasksWithSpecificName(): void
The next 18 lines appear both in tests/Command/ExecuteTaskCommandTest.php:194 and tests/Command/ExecuteTaskCommandTest.php:328.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Mon, 17 May 2021 14:31:52 +0000 by Guillaume Loulier
                    
    {
        $task = new NullTask('foo');
        $logger = $this->createMock(LoggerInterface::class);
        $eventDispatcher = $this->createMock(EventDispatcherInterface::class);

    }
    /**
     * @throws Throwable
     */
    public function testCommandCanExecuteDueTasksWithSpecificName(): void
The next 13 lines appear both in tests/Command/ExecuteTaskCommandTest.php:194 and tests/Command/ExecuteTaskCommandTest.php:261.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Mon, 17 May 2021 14:31:52 +0000 by Guillaume Loulier
                    
    {
        $task = new NullTask('foo');
        $logger = $this->createMock(LoggerInterface::class);
        $eventDispatcher = $this->createMock(EventDispatcherInterface::class);

    }
    /**
     * @throws Throwable
     */
    public function testCommandCanExecuteMultipleDueTasksWithSpecificName(): void
The next 14 lines appear both in tests/Command/ExecuteTaskCommandTest.php:227 and tests/Command/ExecuteTaskCommandTest.php:294.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Mon, 17 May 2021 14:31:52 +0000 by Guillaume Loulier
                    
    {
        $task = new NullTask('foo');
        $secondTask = new NullTask('bar');
        $logger = $this->createMock(LoggerInterface::class);

     * @throws Throwable
     */
    public function testCommandCanExecuteWholeTasksListWithSpecificExpression(): void
    {
        $task = new NullTask('foo');
        $eventDispatcher = $this->createMock(EventDispatcherInterface::class);
The next 12 lines appear both in tests/Command/ExecuteTaskCommandTest.php:364 and tests/Command/ExecuteTaskCommandTest.php:428.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Mon, 17 May 2021 14:31:52 +0000 by Guillaume Loulier
                    
        $worker = $this->createMock(WorkerInterface::class);
        $worker->expects(self::once())->method('execute')->with(self::equalTo(WorkerConfiguration::create()), self::equalTo($task));
        $scheduler = $this->createMock(SchedulerInterface::class);

        $logger = $this->createMock(LoggerInterface::class);
        $eventDispatcher = $this->createMock(EventDispatcher::class);
        $eventDispatcher->expects(self::once())->method('addSubscriber')->with(new StopWorkerOnTaskLimitSubscriber(1, $logger));
        $task = $this->createMock(TaskInterface::class);
The next 20 lines appear both in tests/Command/RebootSchedulerCommandTest.php:103 and tests/Command/RebootSchedulerCommandTest.php:148.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
        $task->expects(self::exactly(3))->method('getName')->willReturn('foo');
        $task->expects(self::once())->method('getExpression')->willReturn('@reboot');
        $task->expects(self::once())->method('getState')->willReturn(TaskInterface::ENABLED);
        $task->expects(self::once())->method('getTags')->willReturn(['app', 'slow']);

        $logger = $this->createMock(LoggerInterface::class);
        $eventDispatcher = $this->createMock(EventDispatcher::class);
        $eventDispatcher->expects(self::once())->method('addSubscriber')->with(new StopWorkerOnTaskLimitSubscriber(1, $logger));
        $task = $this->createMock(TaskInterface::class);
The next 16 lines appear both in tests/Command/RebootSchedulerCommandTest.php:103 and tests/Command/RebootSchedulerCommandTest.php:189.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
        $task->expects(self::exactly(3))->method('getName')->willReturn('foo');
        $task->expects(self::once())->method('getExpression')->willReturn('@reboot');
        $task->expects(self::once())->method('getState')->willReturn(TaskInterface::ENABLED);
        $task->expects(self::once())->method('getTags')->willReturn(['app', 'slow']);

        $commandTester->execute([]);
        self::assertSame(Command::SUCCESS, $commandTester->getStatusCode());
        self::assertStringContainsString('[WARNING] The scheduler cannot be rebooted as the worker is not available', $commandTester->getDisplay());
        self::assertStringContainsString('The process will be retried as soon as the worker is available', $commandTester->getDisplay());
        self::assertStringContainsString('[OK] The scheduler have been rebooted', $commandTester->getDisplay());
The next 13 lines appear both in tests/Command/RebootSchedulerCommandTest.php:131 and tests/Command/RebootSchedulerCommandTest.php:173.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 06 Apr 2021 07:35:14 +0000 by Guillaume Loulier
                    
        self::assertStringContainsString('Name', $commandTester->getDisplay());
        self::assertStringContainsString('foo', $commandTester->getDisplay());
        self::assertStringNotContainsString('bar', $commandTester->getDisplay());
        self::assertStringContainsString('Type', $commandTester->getDisplay());
        self::assertStringContainsString('State', $commandTester->getDisplay());

        self::assertSame(Command::FAILURE, $commandTester->getStatusCode());
        self::assertStringContainsString('[WARNING] The task "foo" has not been retried', $commandTester->getDisplay());
    }
    public function testCommandCanRetryTaskWithForceOption(): void
The next 18 lines appear both in tests/Command/RetryFailedTaskCommandTest.php:133 and tests/Command/RetryFailedTaskCommandTest.php:159.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $logger = $this->createMock(LoggerInterface::class);
        $eventDispatcher = $this->createMock(EventDispatcherInterface::class);
        $eventDispatcher->expects(self::once())->method('dispatch')

                    ],
                ],
            ],
        ]);
        self::assertArrayHasKey('probe', $configuration);
The next 16 lines appear in tests/DependencyInjection/SchedulerBundleConfigurationTest.php:228, tests/DependencyInjection/SchedulerBundleConfigurationTest.php:294 and tests/DependencyInjection/SchedulerBundleConfigurationTest.php:365.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 02 Jun 2021 03:31:07 +0000 by Guillaume Loulier
                    
        self::assertTrue($configuration['probe']['enabled']);
        self::assertSame('/_foo', $configuration['probe']['path']);
        self::assertArrayHasKey('clients', $configuration['probe']);
        self::assertNotEmpty($configuration['probe']['clients']);

        self::assertArrayHasKey('bar.probe', $configuration['tasks']);
        self::assertSame('probe', $configuration['tasks']['bar.probe']['type']);
        self::assertSame('* * * * *', $configuration['tasks']['bar.probe']['expression']);
    }
    public function testConfigurationCanDefineProbeClientsWithExistingTasks(): void
The next 34 lines appear both in tests/DependencyInjection/SchedulerBundleConfigurationTest.php:253 and tests/DependencyInjection/SchedulerBundleConfigurationTest.php:321.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 02 Jun 2021 03:31:07 +0000 by Guillaume Loulier
                    
    {
        $configuration = (new Processor())->processConfiguration(new SchedulerBundleConfiguration(), [
            'scheduler_bundle' => [
                'transport' => [
                    'dsn' => 'cache://memory',

            ],
            'tasks' => [],
            'lock_store' => null,
        ]);
        self::assertTrue($container->hasDefinition(Scheduler::class));
The next 18 lines appear both in tests/DependencyInjection/SchedulerBundleExtensionTest.php:537 and tests/DependencyInjection/SchedulerBundleExtensionTest.php:580.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:18:47 +0000 by Loulier Guillaume
                    
        self::assertTrue($container->hasAlias(SchedulerInterface::class));
        self::assertCount(5, $container->getDefinition(Scheduler::class)->getArguments());
        self::assertSame('Europe/Paris', $container->getDefinition(Scheduler::class)->getArgument(0));
        self::assertInstanceOf(Reference::class, $container->getDefinition(Scheduler::class)->getArgument(1));
        self::assertSame(TransportInterface::class, (string) $container->getDefinition(Scheduler::class)->getArgument(1));

            'tasks' => [],
            'lock_store' => null,
        ]);
        self::assertTrue($container->hasParameter('scheduler.scheduler_mode'));
        self::assertSame('lazy', $container->getParameter('scheduler.scheduler_mode'));
The next 25 lines appear both in tests/DependencyInjection/SchedulerBundleExtensionTest.php:578 and tests/DependencyInjection/SchedulerBundleExtensionTest.php:641.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 02 Jun 2021 03:31:07 +0000 by Guillaume Loulier
                    
        self::assertTrue($container->hasDefinition(Scheduler::class));
        self::assertTrue($container->hasAlias(SchedulerInterface::class));
        self::assertCount(5, $container->getDefinition(Scheduler::class)->getArguments());
        self::assertSame('Europe/Paris', $container->getDefinition(Scheduler::class)->getArgument(0));

            ],
            'tasks' => [],
            'lock_store' => null,
        ]);
        self::assertTrue($container->hasDefinition(Worker::class));
The next 28 lines appear both in tests/DependencyInjection/SchedulerBundleExtensionTest.php:1333 and tests/DependencyInjection/SchedulerBundleExtensionTest.php:1521.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Fri, 15 Apr 2022 08:09:00 +0000 by Guillaume Loulier
                    
        self::assertTrue($container->hasAlias(WorkerInterface::class));
        self::assertCount(8, $container->getDefinition(Worker::class)->getArguments());
        self::assertInstanceOf(Reference::class, $container->getDefinition(Worker::class)->getArgument(0));
        self::assertSame(SchedulerInterface::class, (string) $container->getDefinition(Worker::class)->getArgument(0));
        self::assertSame(ContainerInterface::EXCEPTION_ON_INVALID_REFERENCE, $container->getDefinition(Worker::class)->getArgument(0)->getInvalidBehavior());

        self::assertSame(ContainerInterface::EXCEPTION_ON_INVALID_REFERENCE, $container->getDefinition(Worker::class)->getArgument(6)->getInvalidBehavior());
        self::assertInstanceOf(Reference::class, $container->getDefinition(Worker::class)->getArgument(7));
        self::assertSame(LoggerInterface::class, (string) $container->getDefinition(Worker::class)->getArgument(7));
        self::assertSame(ContainerInterface::NULL_ON_INVALID_REFERENCE, $container->getDefinition(Worker::class)->getArgument(7)->getInvalidBehavior());
        self::assertFalse($container->getDefinition(Worker::class)->isPublic());
        self::assertCount(4, $container->getDefinition(Worker::class)->getTags());
The next 9 lines appear both in tests/DependencyInjection/SchedulerBundleExtensionTest.php:1361 and tests/DependencyInjection/SchedulerBundleExtensionTest.php:1548.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Fri, 15 Apr 2022 08:09:00 +0000 by Guillaume Loulier
                    
        self::assertTrue($container->getDefinition(Worker::class)->hasTag('scheduler.worker'));
        self::assertTrue($container->getDefinition(Worker::class)->hasTag('monolog.logger'));
        self::assertSame('scheduler', $container->getDefinition(Worker::class)->getTag('monolog.logger')[0]['channel']);
        self::assertTrue($container->getDefinition(Worker::class)->hasTag('container.hot_path'));
        self::assertTrue($container->getDefinition(Worker::class)->hasTag('container.preload'));

        self::assertTrue($container->hasDefinition('scheduler.lock_store.factory'));
        self::assertSame(LockFactory::class, $container->getDefinition('scheduler.lock_store.factory')->getClass());
        self::assertFalse($container->getDefinition('scheduler.lock_store.factory')->isPublic());
        self::assertCount(1, $container->getDefinition('scheduler.lock_store.factory')->getArguments());
        self::assertInstanceOf(Reference::class, $container->getDefinition('scheduler.lock_store.factory')->getArgument('$store'));
        self::assertSame('scheduler.lock_store.store', (string) $container->getDefinition('scheduler.lock_store.factory')->getArgument('$store'));
The next 12 lines appear both in tests/DependencyInjection/SchedulerBundleExtensionTest.php:1387 and tests/DependencyInjection/SchedulerBundleExtensionTest.php:1561.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertSame(ContainerInterface::EXCEPTION_ON_INVALID_REFERENCE, $container->getDefinition('scheduler.lock_store.factory')->getArgument('$store')->getInvalidBehavior());
        self::assertCount(1, $container->getDefinition('scheduler.lock_store.factory')->getMethodCalls());
        self::assertSame('setLogger', $container->getDefinition('scheduler.lock_store.factory')->getMethodCalls()[0][0]);
        self::assertInstanceOf(Reference::class, $container->getDefinition('scheduler.lock_store.factory')->getMethodCalls()[0][1][0]);
        self::assertSame(LoggerInterface::class, (string) $container->getDefinition('scheduler.lock_store.factory')->getMethodCalls()[0][1][0]);

            'expression' => '*/5 * * * *',
            'description' => 'A simple cache clear task',
            'options' => [
                'env' => 'test',
            ],
        ], $container->getDefinition('scheduler._foo_task')->getArgument(0));
The next 16 lines appear both in tests/DependencyInjection/SchedulerBundleExtensionTest.php:1604 and tests/DependencyInjection/SchedulerBundleExtensionTest.php:1660.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 02 Jun 2021 03:31:07 +0000 by Guillaume Loulier
                    
        self::assertFalse($container->getDefinition('scheduler._foo_task')->isPublic());
        $factory = $container->getDefinition('scheduler._foo_task')->getFactory();
        self::assertIsArray($factory);
        self::assertArrayHasKey(0, $factory);

        self::assertSame('scheduler.middleware', $container->getDefinition(MiddlewareRegistry::class)->getArgument(0)->getTag());
        self::assertCount(1, $container->getDefinition(MiddlewareRegistry::class)->getTags());
        self::assertTrue($container->getDefinition(MiddlewareRegistry::class)->hasTag('container.preload'));
        self::assertSame(MiddlewareRegistry::class, $container->getDefinition(MiddlewareRegistry::class)->getTag('container.preload')[0]['class']);
        self::assertTrue($container->hasAlias(SchedulerMiddlewareStackInterface::class));
The next 14 lines appear both in tests/DependencyInjection/SchedulerBundleExtensionTest.php:1768 and tests/DependencyInjection/SchedulerBundleExtensionTest.php:1886.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 26 Apr 2022 07:44:31 +0000 by Guillaume Loulier
                    
        self::assertTrue($container->hasDefinition(SchedulerMiddlewareStack::class));
        self::assertFalse($container->getDefinition(SchedulerMiddlewareStack::class)->isPublic());
        self::assertCount(1, $container->getDefinition(SchedulerMiddlewareStack::class)->getArguments());
        self::assertInstanceOf(Reference::class, $container->getDefinition(SchedulerMiddlewareStack::class)->getArgument(0));
        self::assertSame(MiddlewareRegistryInterface::class, (string) $container->getDefinition(SchedulerMiddlewareStack::class)->getArgument(0));

        self::assertTrue($container->getDefinition(SchedulerMiddlewareStack::class)->hasTag('scheduler.middleware_hub'));
        self::assertTrue($container->getDefinition(SchedulerMiddlewareStack::class)->hasTag('container.hot_path'));
        self::assertTrue($container->getDefinition(SchedulerMiddlewareStack::class)->hasTag('container.preload'));
        self::assertSame(SchedulerMiddlewareStack::class, $container->getDefinition(SchedulerMiddlewareStack::class)->getTag('container.preload')[0]['class']);
        self::assertTrue($container->hasAlias(WorkerMiddlewareStackInterface::class));
The next 14 lines appear both in tests/DependencyInjection/SchedulerBundleExtensionTest.php:1781 and tests/DependencyInjection/SchedulerBundleExtensionTest.php:1943.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 26 Apr 2022 07:44:31 +0000 by Guillaume Loulier
                    
        self::assertTrue($container->hasDefinition(WorkerMiddlewareStack::class));
        self::assertFalse($container->getDefinition(WorkerMiddlewareStack::class)->isPublic());
        self::assertCount(1, $container->getDefinition(WorkerMiddlewareStack::class)->getArguments());
        self::assertInstanceOf(Reference::class, $container->getDefinition(WorkerMiddlewareStack::class)->getArgument(0));
        self::assertSame(MiddlewareRegistryInterface::class, (string) $container->getDefinition(WorkerMiddlewareStack::class)->getArgument(0));

        self::assertArrayHasKey('task_filter', $request->attributes->all());
        self::assertSame('app.bar', $request->attributes->get('task_filter'));
    }
    public function testValidPathCanBeHandledWithValidExpression(): void
The next 27 lines appear both in tests/EventListener/TaskSubscriberTest.php:144 and tests/EventListener/TaskSubscriberTest.php:193.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $objectNormalizer = new ObjectNormalizer(null, null, null, new PropertyInfoExtractor([], [new PhpDocExtractor(), new ReflectionExtractor()]));
        $notificationTaskBagNormalizer = new NotificationTaskBagNormalizer($objectNormalizer);
        $lockTaskBagNormalizer = new AccessLockBagNormalizer($objectNormalizer);

        $workerLifecycleSubscriber = new WorkerLifecycleSubscriber($logger);
        $workerLifecycleSubscriber->onWorkerRestarted(new WorkerRestartedEvent($worker));
    }
    public function testSubscriberLogOnWorkerRestarted(): void
The next 11 lines appear in tests/EventListener/WorkerLifecycleSubscriberTest.php:92, tests/EventListener/WorkerLifecycleSubscriberTest.php:128, tests/EventListener/WorkerLifecycleSubscriberTest.php:164 and tests/EventListener/WorkerLifecycleSubscriberTest.php:199.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 27 Jan 2021 16:24:45 +0000 by Guillaume Loulier
                    
    {
        $task = $this->createMock(TaskInterface::class);
        $task->expects(self::once())->method('getName')->willReturn('foo');
        $worker = $this->createMock(WorkerInterface::class);

    /**
     * @throws Exception {@see Scheduler::__construct()}
     * @throws Throwable {@see SchedulerInterface::schedule()}
     */
    public function testSchedulerCanScheduleTasksWithBeforeSchedulingNotificationAndWithNotifier(): void
The next 18 lines appear both in tests/FiberSchedulerTest.php:180 and tests/FiberSchedulerTest.php:234.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
    {
        $notification = $this->createMock(Notification::class);
        $recipient = $this->createMock(Recipient::class);
        $notifier = $this->createMock(NotifierInterface::class);

                'execution_mode' => 'first_in_first_out',
            ]), new SchedulePolicyOrchestrator([
                new FirstInFirstOutPolicy(),
            ])),
            new SchedulerMiddlewareStack(),
            new EventDispatcher()
The next 29 lines appear both in tests/FiberSchedulerTest.php:572 and tests/SchedulerTest.php:569.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        ));
        $scheduler->schedule($task);
        $scheduler->schedule($secondTask);
        $scheduler->schedule($thirdTask);

                'execution_mode' => 'first_in_first_out',
            ]), new SchedulePolicyOrchestrator([
                new FirstInFirstOutPolicy(),
            ])),
            new SchedulerMiddlewareStack(),
            new EventDispatcher()
The next 32 lines appear both in tests/FiberSchedulerTest.php:608 and tests/SchedulerTest.php:605.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        ));
        $scheduler->schedule($task);
        $scheduler->schedule($secondTask);
        $scheduler->schedule($thirdTask);

                'execution_mode' => 'first_in_first_out',
            ]), new SchedulePolicyOrchestrator([
                new FirstInFirstOutPolicy(),
            ])),
            new SchedulerMiddlewareStack(),
            new EventDispatcher()
The next 30 lines appear both in tests/FiberSchedulerTest.php:647 and tests/SchedulerTest.php:644.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        ));
        $scheduler->schedule($task);
        $scheduler->schedule($secondTask);
        $scheduler->schedule($thirdTask);

    {
        $scheduler = new FiberScheduler(new Scheduler('UTC', new InMemoryTransport(new InMemoryConfiguration([
            'execution_mode' => 'first_in_first_out',
        ]), new SchedulePolicyOrchestrator([
            new FirstInFirstOutPolicy(),
        ])), new SchedulerMiddlewareStack(), new EventDispatcher()));
The next 23 lines appear both in tests/FiberSchedulerTest.php:816 and tests/SchedulerTest.php:813.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        $scheduler->schedule($task);
        self::assertInstanceOf(LazyTaskList::class, $scheduler->getTasks(true));
        self::assertCount(1, $scheduler->getTasks(true));

        $updatedTask = new NullTask('bar');
        $bus = $this->createMock(MessageBusInterface::class);
        $bus->expects(self::never())->method('dispatch');
        $scheduler = new FiberScheduler(new Scheduler('UTC', new InMemoryTransport(new InMemoryConfiguration(), new SchedulePolicyOrchestrator([
The next 32 lines appear both in tests/FiberSchedulerTest.php:838 and tests/SchedulerTest.php:835.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 26 Apr 2022 07:44:31 +0000 by Guillaume Loulier
                    
            new FirstInFirstOutPolicy(),
        ])), new SchedulerMiddlewareStack(new MiddlewareRegistry([])), new EventDispatcher(), $bus));
        $scheduler->schedule($task);
        self::assertCount(1, $scheduler->getTasks());

                    new TaskToUpdateMessageHandler($transport),
                ],
            ])),
        ]);
        $scheduler = new FiberScheduler(new Scheduler('UTC', $transport, new SchedulerMiddlewareStack(new MiddlewareRegistry([])), new EventDispatcher(), $bus));
The next 24 lines appear both in tests/FiberSchedulerTest.php:869 and tests/SchedulerTest.php:866.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 26 Apr 2022 07:44:31 +0000 by Guillaume Loulier
                    
        $scheduler->schedule($task);
        self::assertCount(1, $scheduler->getTasks());
        self::assertSame('* * * * *', $scheduler->getTasks()->get('foo')->getExpression());

    public function testTaskCanBeUpdatedThenRetrieved(TaskInterface $task): void
    {
        $bus = $this->createMock(MessageBusInterface::class);
        $bus->expects(self::never())->method('dispatch');
        $scheduler = new FiberScheduler(new Scheduler('UTC', new InMemoryTransport(new InMemoryConfiguration([
The next 27 lines appear both in tests/FiberSchedulerTest.php:892 and tests/SchedulerTest.php:889.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 26 Apr 2022 07:44:31 +0000 by Guillaume Loulier
                    
            'execution_mode' => 'first_in_first_out',
        ]), new SchedulePolicyOrchestrator([
            new FirstInFirstOutPolicy(),
        ])), new SchedulerMiddlewareStack(new MiddlewareRegistry([])), new EventDispatcher(), $bus));

    public function testTaskCanBeUpdatedThenLazilyRetrieved(TaskInterface $task): void
    {
        $bus = $this->createMock(MessageBusInterface::class);
        $bus->expects(self::never())->method('dispatch');
        $scheduler = new FiberScheduler(new Scheduler('UTC', new InMemoryTransport(new InMemoryConfiguration([
The next 29 lines appear both in tests/FiberSchedulerTest.php:918 and tests/SchedulerTest.php:915.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 26 Apr 2022 07:44:31 +0000 by Guillaume Loulier
                    
            'execution_mode' => 'first_in_first_out',
        ]), new SchedulePolicyOrchestrator([
            new FirstInFirstOutPolicy(),
        ])), new SchedulerMiddlewareStack(new MiddlewareRegistry([])), new EventDispatcher(), $bus));

        $scheduler = new FiberScheduler(new Scheduler('UTC', new InMemoryTransport(new InMemoryConfiguration([
            'execution_mode' => 'first_in_first_out',
        ]), new SchedulePolicyOrchestrator([
            new FirstInFirstOutPolicy(),
        ])), new SchedulerMiddlewareStack([]), new EventDispatcher()));
The next 45 lines appear both in tests/FiberSchedulerTest.php:1419 and tests/SchedulerTest.php:1417.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        $scheduler->schedule(new NullTask('foo'));
        $list = $scheduler->getTasks();
        self::assertCount(1, $list);

        $worker = new Worker($scheduler, new RunnerRegistry([
            new NullTaskRunner(),
        ]), new ExecutionPolicyRegistry([
            new DefaultPolicy(),
        ]), new TaskExecutionTracker(new Stopwatch()), new WorkerMiddlewareStack([
            new SingleRunTaskMiddleware($transport),
The next 38 lines appear both in tests/FiberSchedulerTest.php:1665 and tests/LazySchedulerTest.php:728.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 27 Apr 2022 03:35:14 +0000 by Guillaume Loulier
                    
            new TaskUpdateMiddleware($transport),
            new TaskLockBagMiddleware($lockFactory),
        ]), $eventDispatcher, $lockFactory, $logger);
        $worker->execute(WorkerConfiguration::create());

        self::assertFalse($scheduler->isInitialized());
        $scheduler->schedule(new NullTask('foo'));
        $scheduler->schedule(new NullTask('bar'));
        $scheduler->schedule(new NullTask('reboot'));
        $scheduler->preempt('foo', static fn (TaskInterface $task): bool => $task->getName() === 'reboot');
The next 94 lines appear both in tests/LazySchedulerTest.php:719 and tests/SchedulerTest.php:1648.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 26 Apr 2022 07:44:31 +0000 by Guillaume Loulier
                    
        $lockFactory = new LockFactory(new InMemoryStore());
        $worker = new Worker($scheduler, new RunnerRegistry([
            new NullTaskRunner(),

        $schedulerMiddlewareStack = new FiberAwareSchedulerMiddlewareStack(new SchedulerMiddlewareStack(new MiddlewareRegistry([
            $middleware,
            $secondMiddleware,
        ])), $logger);
        $schedulerMiddlewareStack->runPreSchedulingMiddleware($task, $scheduler);
The next 19 lines appear both in tests/Middleware/FiberAwareSchedulerMiddlewareStackTest.php:79 and tests/Middleware/SchedulerMiddlewareStackTest.php:69.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 26 Apr 2022 07:44:31 +0000 by Guillaume Loulier
                    
    }
    /**
     * @throws Throwable {@see SchedulerMiddlewareStack::runPreSchedulingMiddleware()}
     */

            $secondMiddleware,
            $thirdMiddleware,
            $fourthMiddleware,
        ])), $logger);
        self::expectException(RuntimeException::class);
The next 35 lines appear both in tests/Middleware/FiberAwareSchedulerMiddlewareStackTest.php:121 and tests/Middleware/SchedulerMiddlewareStackTest.php:108.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 26 Apr 2022 07:44:31 +0000 by Guillaume Loulier
                    
        self::expectExceptionMessage('An error occurred');
        self::expectExceptionCode(0);
        $schedulerMiddlewareStack->runPreSchedulingMiddleware($task, $scheduler);
    }

        $thirdOrderedMiddleware->expects(self::exactly(2))->method('getPriority')->willReturn(0);
        $thirdOrderedMiddleware->expects(self::once())->method('preScheduling')->with(self::equalTo($task), self::equalTo($scheduler));
        $fourthOrderedMiddleware = $this->createMock(OrderedMiddleware::class);
        $fourthOrderedMiddleware->expects(self::exactly(2))->method('getPriority')->willReturn(1);
        $fourthOrderedMiddleware->expects(self::once())->method('preScheduling')->with(self::equalTo($task), self::equalTo($scheduler));
The next 15 lines appear both in tests/Middleware/FiberAwareSchedulerMiddlewareStackTest.php:149 and tests/Middleware/FiberAwareSchedulerMiddlewareStackTest.php:182.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 26 Apr 2022 07:44:31 +0000 by Guillaume Loulier
                    
        $middleware = $this->createMock(PreSchedulingMiddlewareInterface::class);
        $middleware->expects(self::once())->method('preScheduling')->with(self::equalTo($task), self::equalTo($scheduler));
        $secondMiddleware = $this->createMock(PostSchedulingMiddlewareInterface::class);

            $secondOrderedMiddleware,
            $thirdOrderedMiddleware,
            $fourthOrderedMiddleware,
        ])), $logger);
        $schedulerMiddlewareStack->runPreSchedulingMiddleware($task, $scheduler);
The next 20 lines appear both in tests/Middleware/FiberAwareSchedulerMiddlewareStackTest.php:169 and tests/Middleware/SchedulerMiddlewareStackTest.php:153.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 26 Apr 2022 07:44:31 +0000 by Guillaume Loulier
                    
    }
    /**
     * @throws Throwable {@see SchedulerMiddlewareStack::runPreSchedulingMiddleware()}
     */

        self::assertSame(Output::ERROR, $output->getType());
        self::assertNull($output->getOutput());
        self::assertInstanceOf(ShellTask::class, $output->getTask());
    }
    public function testApplicationCanReturnValidCode(): void
The next 11 lines appear both in tests/Runner/CommandTaskRunnerTest.php:48 and tests/Runner/CommandTaskRunnerTest.php:69.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Thu, 16 Sep 2021 10:09:35 +0000 by Guillaume Loulier
                    
    {
        $worker = $this->createMock(WorkerInterface::class);
        $commandTask = new CommandTask('foo', 'app:foo');

        self::assertSame('The probe state is invalid', $output->getOutput());
        self::assertInstanceOf(ProbeTask::class, $output->getTask());
        self::assertNull($output->getTask()->getExecutionState());
    }
    public function testRunnerCanRunTaskWithInvalidProbeStateAndTaskFailureEnabled(): void
The next 17 lines appear both in tests/Runner/ProbeTaskRunnerTest.php:64 and tests/Runner/ProbeTaskRunnerTest.php:88.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 02 Jun 2021 03:31:07 +0000 by Guillaume Loulier
                    
    {
        $worker = $this->createMock(WorkerInterface::class);
        $response = $this->createMock(ResponseInterface::class);
        $response->expects(self::once())->method('toArray')->with(self::equalTo(true))->willReturn([

    /**
     * @throws Exception {@see Scheduler::__construct()}
     * @throws Throwable {@see SchedulerInterface::schedule()}
     */
    public function testSchedulerCanScheduleTasksWithBeforeSchedulingNotificationAndWithNotifier(): void
The next 18 lines appear both in tests/SchedulerTest.php:175 and tests/SchedulerTest.php:229.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 26 Jan 2021 06:16:21 +0000 by Guillaume Loulier
                    
    {
        $notification = $this->createMock(Notification::class);
        $recipient = $this->createMock(Recipient::class);
        $notifier = $this->createMock(NotifierInterface::class);

        self::assertFalse($normalizer->supportsNormalization(new stdClass()));
        self::assertTrue($normalizer->supportsNormalization(new SchedulerConfiguration(new DateTimeZone('UTC'), new DateTimeImmutable(), new NullTask('foo'))));
    }
    public function testNormalizerCanNormalize(): void
The next 31 lines appear both in tests/Serializer/SchedulerConfigurationNormalizerTest.php:48 and tests/Serializer/SchedulerConfigurationNormalizerTest.php:103.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 26 Apr 2022 07:44:31 +0000 by Guillaume Loulier
                    
    {
        $objectNormalizer = new ObjectNormalizer(null, null, null, new PropertyInfoExtractor([], [new PhpDocExtractor(), new ReflectionExtractor()]));
        $notificationTaskBagNormalizer = new NotificationTaskBagNormalizer($objectNormalizer);
        $lockTaskBagNormalizer = new AccessLockBagNormalizer($objectNormalizer);

        ]));
        self::assertSame('nice', $cacheTransport->getExecutionMode());
    }
    public function testTransportCannotReturnUndefinedTask(): void
The next 29 lines appear both in tests/Transport/CacheTransportTest.php:72 and tests/Transport/CacheTransportTest.php:278.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 06 Apr 2021 07:35:14 +0000 by Guillaume Loulier
                    
    {
        $objectNormalizer = new ObjectNormalizer(null, null, null, new PropertyInfoExtractor([], [new PhpDocExtractor(), new ReflectionExtractor()]));
        $lockTaskBagNormalizer = new AccessLockBagNormalizer($objectNormalizer);
        $serializer = new Serializer([

        $cacheTransport->update('foo', new ShellTask('foo', []));
        self::assertInstanceOf(ShellTask::class, $cacheTransport->get('foo'));
    }
    public function testTransportCannotPauseAlreadyPausedTask(): void
The next 28 lines appear both in tests/Transport/CacheTransportTest.php:340 and tests/Transport/CacheTransportTest.php:374.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 06 Apr 2021 07:35:14 +0000 by Guillaume Loulier
                    
    {
        $objectNormalizer = new ObjectNormalizer(null, null, null, new PropertyInfoExtractor([], [new PhpDocExtractor(), new ReflectionExtractor()]));
        $lockTaskBagNormalizer = new AccessLockBagNormalizer($objectNormalizer);
        $serializer = new Serializer([

        $cacheTransport->update('foo', new ShellTask('foo', []));
        self::assertInstanceOf(ShellTask::class, $cacheTransport->get('foo'));
    }
    public function testTransportCannotPauseAlreadyPausedTask(): void
The next 27 lines appear both in tests/Transport/CacheTransportTest.php:340 and tests/Transport/CacheTransportTest.php:436.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 06 Apr 2021 07:35:14 +0000 by Guillaume Loulier
                    
    {
        $objectNormalizer = new ObjectNormalizer(null, null, null, new PropertyInfoExtractor([], [new PhpDocExtractor(), new ReflectionExtractor()]));
        $lockTaskBagNormalizer = new AccessLockBagNormalizer($objectNormalizer);
        $serializer = new Serializer([

    }
    /**
     * @throws Throwable {@see TransportInterface::list()}
     */
    public function testTransportCannotDeleteUndefinedTask(): void
The next 29 lines appear both in tests/Transport/CacheTransportTest.php:471 and tests/Transport/CacheTransportTest.php:512.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 06 Apr 2021 07:35:14 +0000 by Guillaume Loulier
                    
    {
        $objectNormalizer = new ObjectNormalizer(null, null, null, new PropertyInfoExtractor([], [new PhpDocExtractor(), new ReflectionExtractor()]));
        $lockTaskBagNormalizer = new AccessLockBagNormalizer($objectNormalizer);
        $serializer = new Serializer([

        self::expectExceptionMessage('All the transports failed to execute the requested action');
        self::expectExceptionCode(0);
        $failOverTransport->get('foo');
    }
    public function testTransportCanRetrieveTask(): void
The next 21 lines appear both in tests/Transport/FailOverTransportTest.php:94 and tests/Transport/FailOverTransportTest.php:117.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $firstTransport = $this->createMock(TransportInterface::class);
        $firstTransport->expects(self::once())->method('get')
            ->with(self::equalTo('foo'), self::equalTo(false))
            ->willThrowException(new RuntimeException('Task not found'))

        ]), new InMemoryConfiguration());
        self::expectException(TransportException::class);
        self::expectExceptionMessage('All the transports failed to execute the requested action');
        self::expectExceptionCode(0);
        $failOverTransport->update('foo', $task);
The next 16 lines appear both in tests/Transport/FailOverTransportTest.php:410 and tests/Transport/RoundRobinTransportTest.php:376.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 06 Apr 2021 07:35:14 +0000 by Guillaume Loulier
                    
    }
    public function testTransportCanUpdateTask(): void
    {
        $task = $this->createMock(TaskInterface::class);

        self::expectException(InvalidArgumentException::class);
        self::expectExceptionMessage('The "bar" task does not exist');
        $filesystemTransport->get('bar');
    }
    public function testTaskCanBeRetrieved(): void
The next 30 lines appear in tests/Transport/FilesystemTransportTest.php:249, tests/Transport/FilesystemTransportTest.php:286 and tests/Transport/FilesystemTransportTest.php:437.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $objectNormalizer = new ObjectNormalizer(null, null, null, new PropertyInfoExtractor([], [new PhpDocExtractor(), new ReflectionExtractor()]));
        $lockTaskBagNormalizer = new AccessLockBagNormalizer($objectNormalizer);
        $serializer = new Serializer([

        self::expectException(InvalidArgumentException::class);
        self::expectExceptionMessage('The "bar" task does not exist');
        $filesystemTransport->get('bar');
    }
    public function testTaskCanBeRetrieved(): void
The next 35 lines appear in tests/Transport/FilesystemTransportTest.php:249, tests/Transport/FilesystemTransportTest.php:513 and tests/Transport/FilesystemTransportTest.php:550.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $objectNormalizer = new ObjectNormalizer(null, null, null, new PropertyInfoExtractor([], [new PhpDocExtractor(), new ReflectionExtractor()]));
        $lockTaskBagNormalizer = new AccessLockBagNormalizer($objectNormalizer);
        $serializer = new Serializer([

        self::expectException(InvalidArgumentException::class);
        self::expectExceptionMessage('The "bar" task does not exist');
        $filesystemTransport->get('bar');
    }
    public function testTaskCanBeRetrieved(): void
The next 29 lines appear both in tests/Transport/FilesystemTransportTest.php:249 and tests/Transport/FilesystemTransportTest.php:328.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $objectNormalizer = new ObjectNormalizer(null, null, null, new PropertyInfoExtractor([], [new PhpDocExtractor(), new ReflectionExtractor()]));
        $lockTaskBagNormalizer = new AccessLockBagNormalizer($objectNormalizer);
        $serializer = new Serializer([

        self::expectException(InvalidArgumentException::class);
        self::expectExceptionMessage('The "bar" task does not exist');
        $filesystemTransport->get('bar');
    }
    public function testTaskCanBeRetrieved(): void
The next 32 lines appear both in tests/Transport/FilesystemTransportTest.php:249 and tests/Transport/FilesystemTransportTest.php:472.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $objectNormalizer = new ObjectNormalizer(null, null, null, new PropertyInfoExtractor([], [new PhpDocExtractor(), new ReflectionExtractor()]));
        $lockTaskBagNormalizer = new AccessLockBagNormalizer($objectNormalizer);
        $serializer = new Serializer([

        self::expectException(InvalidArgumentException::class);
        self::expectExceptionMessage('The "bar" task does not exist');
        $filesystemTransport->get('bar');
    }
    public function testTaskCanBeRetrieved(): void
The next 38 lines appear both in tests/Transport/FilesystemTransportTest.php:249 and tests/Transport/FilesystemTransportTest.php:595.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $objectNormalizer = new ObjectNormalizer(null, null, null, new PropertyInfoExtractor([], [new PhpDocExtractor(), new ReflectionExtractor()]));
        $lockTaskBagNormalizer = new AccessLockBagNormalizer($objectNormalizer);
        $serializer = new Serializer([

    }
    /**
     * @throws Throwable {@see TransportInterface::list()}
     */
    public function testTransportCannotReturnAListWithFailingTransports(): void
The next 29 lines appear both in tests/Transport/LongTailTransportTest.php:157 and tests/Transport/LongTailTransportTest.php:186.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 13 Jan 2021 13:13:35 +0000 by Loulier Guillaume
                    
    {
        $secondTaskList = new TaskList([
            new NullTask('foo'),
        ]);

            new TaskLockBagMiddleware($lockFactory),
        ]), $eventDispatcher, $lockFactory, $logger);
        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $configuration->stop();
The next 15 lines appear both in tests/Worker/FiberWorkerTest.php:128 and tests/Worker/WorkerTest.php:121.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        $worker->execute($configuration);
        self::assertSame(0, $worker->getConfiguration()->getExecutedTasksCount());
        self::assertNull($worker->getConfiguration()->getForkedFrom());

            new TaskLockBagMiddleware($lockFactory),
        ]), $eventDispatcher, $lockFactory, new NullLogger());
        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $configuration->setSleepDurationDelay(5);
The next 44 lines appear both in tests/Worker/FiberWorkerTest.php:170 and tests/Worker/WorkerTest.php:162.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        $worker->execute($configuration);
        $forkedWorker = $worker->fork();
        self::assertNotSame($forkedWorker, $worker);

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertNull($worker->getLastExecutedTask());
The next 35 lines appear both in tests/Worker/FiberWorkerTest.php:224 and tests/Worker/WorkerTest.php:212.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertCount(1, $worker->getFailedTasks());
        $failedTask = $worker->getFailedTasks()->get('foo.failed');
        self::assertInstanceOf(FailedTask::class, $failedTask);

            new TaskLockBagMiddleware($lockFactory),
        ]), $eventDispatcher, $lockFactory, $logger);
        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $configuration->stop();
The next 50 lines appear both in tests/Worker/FiberWorkerTest.php:266 and tests/Worker/WorkerTest.php:253.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        $worker->execute($configuration);
        self::assertNull($worker->getLastExecutedTask());
        self::assertTrue($worker->getConfiguration()->shouldStop());

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertNull($task->getExecutionState());
The next 39 lines appear both in tests/Worker/FiberWorkerTest.php:326 and tests/Worker/WorkerTest.php:310.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertSame(TaskInterface::SUCCEED, $secondTask->getExecutionState());
        self::assertSame($secondTask, $worker->getLastExecutedTask());
    }
    /**

    {
        $task = new NullTask('foo', [
            'execution_delay' => 1_000_000,
        ]);
        $logger = $this->createMock(LoggerInterface::class);
The next 39 lines appear both in tests/Worker/FiberWorkerTest.php:342 and tests/Worker/FiberWorkerTest.php:723.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        $logger->expects(self::never())->method('info');
        $tracker = $this->createMock(TaskExecutionTrackerInterface::class);
        $tracker->expects(self::once())->method('startTracking');
        $tracker->expects(self::once())->method('endTracking');

    {
        $task = new NullTask('foo', [
            'execution_delay' => 1_000_000,
        ]);
        $logger = $this->createMock(LoggerInterface::class);
The next 26 lines appear both in tests/Worker/FiberWorkerTest.php:342 and tests/Worker/FiberWorkerTest.php:584.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        $logger->expects(self::never())->method('info');
        $tracker = $this->createMock(TaskExecutionTrackerInterface::class);
        $tracker->expects(self::once())->method('startTracking');
        $tracker->expects(self::once())->method('endTracking');

        ]);
        $logger = $this->createMock(LoggerInterface::class);
        $logger->expects(self::never())->method('info');
        $tracker = $this->createMock(TaskExecutionTrackerInterface::class);
The next 39 lines appear both in tests/Worker/FiberWorkerTest.php:345 and tests/Worker/FiberWorkerTest.php:923.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        $tracker->expects(self::once())->method('startTracking');
        $tracker->expects(self::once())->method('endTracking');
        $transport = new InMemoryTransport(new InMemoryConfiguration(), new SchedulePolicyOrchestrator([
            new FirstInFirstOutPolicy(),

        ]);
        $logger = $this->createMock(LoggerInterface::class);
        $logger->expects(self::never())->method('info');
        $tracker = $this->createMock(TaskExecutionTrackerInterface::class);
The next 24 lines appear both in tests/Worker/FiberWorkerTest.php:345 and tests/Worker/FiberWorkerTest.php:870.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        $tracker->expects(self::once())->method('startTracking');
        $tracker->expects(self::once())->method('endTracking');
        $transport = new InMemoryTransport(new InMemoryConfiguration(), new SchedulePolicyOrchestrator([
            new FirstInFirstOutPolicy(),

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertSame($task, $worker->getLastExecutedTask());
The next 35 lines appear both in tests/Worker/FiberWorkerTest.php:374 and tests/Worker/WorkerTest.php:355.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
    }
    /**
     * @throws Throwable
     */

        $logger = $this->createMock(LoggerInterface::class);
        $logger->expects(self::never())->method('info');
        $tracker = $this->createMock(TaskExecutionTrackerInterface::class);
        $tracker->expects(self::never())->method('startTracking')->with(self::equalTo($task));
        $tracker->expects(self::never())->method('endTracking')->with(self::equalTo($task));
The next 29 lines appear both in tests/Worker/FiberWorkerTest.php:391 and tests/Worker/FiberWorkerTest.php:490.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        $transport = new InMemoryTransport(new InMemoryConfiguration(), new SchedulePolicyOrchestrator([
            new FirstInFirstOutPolicy(),
        ]));

        $tracker = $this->createMock(TaskExecutionTrackerInterface::class);
        $tracker->expects(self::never())->method('startTracking')->with(self::equalTo($task));
        $tracker->expects(self::never())->method('endTracking')->with(self::equalTo($task));
        $transport = new InMemoryTransport(new InMemoryConfiguration(), new SchedulePolicyOrchestrator([
The next 27 lines appear both in tests/Worker/FiberWorkerTest.php:393 and tests/Worker/FiberWorkerTest.php:591.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 27 Apr 2022 03:35:14 +0000 by Guillaume Loulier
                    
            new FirstInFirstOutPolicy(),
        ]));
        $scheduler = new Scheduler('UTC', $transport, new SchedulerMiddlewareStack(), new EventDispatcher());
        $scheduler->schedule($task);

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertNull($worker->getLastExecutedTask());
The next 41 lines appear both in tests/Worker/FiberWorkerTest.php:419 and tests/Worker/WorkerTest.php:397.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertCount(1, $worker->getFailedTasks());
    }
    /**
     * @throws Throwable {@see TaskListInterface::add()}

        $scheduler->schedule($validTask);
        $eventDispatcher = new EventDispatcher();
        $eventDispatcher->addSubscriber(new StopWorkerOnTaskLimitSubscriber(2));
        $lockFactory = new LockFactory(new InMemoryStore());
The next 26 lines appear both in tests/Worker/FiberWorkerTest.php:454 and tests/Worker/FiberWorkerTest.php:553.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        $worker = new Worker($scheduler, new RunnerRegistry([
            new NullTaskRunner(),
        ]), new ExecutionPolicyRegistry([
            new FiberPolicy(),

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertCount(1, $worker->getFailedTasks());
The next 38 lines appear both in tests/Worker/FiberWorkerTest.php:470 and tests/Worker/WorkerTest.php:445.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertInstanceOf(FailedTask::class, $worker->getFailedTasks()->get('foo.failed'));
        self::assertNotNull($worker->getLastExecutedTask());
        self::assertSame($validTask, $worker->getLastExecutedTask());
    }

    {
        $task = new NullTask('foo', [
            'before_executing' => static fn (): bool => true,
        ]);
        $logger = $this->createMock(LoggerInterface::class);
The next 12 lines appear both in tests/Worker/FiberWorkerTest.php:485 and tests/Worker/FiberWorkerTest.php:1219.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        $logger->expects(self::never())->method('info');
        $tracker = $this->createMock(TaskExecutionTrackerInterface::class);
        $tracker->expects(self::once())->method('startTracking')->with(self::equalTo($task));
        $tracker->expects(self::once())->method('endTracking')->with(self::equalTo($task));

    {
        $task = new NullTask('foo', [
            'before_executing' => static fn (): bool => true,
        ]);
        $logger = $this->createMock(LoggerInterface::class);
The next 41 lines appear both in tests/Worker/FiberWorkerTest.php:485 and tests/Worker/FiberWorkerTest.php:1163.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        $logger->expects(self::never())->method('info');
        $tracker = $this->createMock(TaskExecutionTrackerInterface::class);
        $tracker->expects(self::once())->method('startTracking')->with(self::equalTo($task));
        $tracker->expects(self::once())->method('endTracking')->with(self::equalTo($task));

    {
        $task = new NullTask('foo', [
            'before_executing' => static fn (): bool => true,
        ]);
        $logger = $this->createMock(LoggerInterface::class);
The next 25 lines appear both in tests/Worker/FiberWorkerTest.php:485 and tests/Worker/FiberWorkerTest.php:1111.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        $logger->expects(self::never())->method('info');
        $tracker = $this->createMock(TaskExecutionTrackerInterface::class);
        $tracker->expects(self::once())->method('startTracking')->with(self::equalTo($task));
        $tracker->expects(self::once())->method('endTracking')->with(self::equalTo($task));

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertSame($task, $worker->getLastExecutedTask());
The next 41 lines appear both in tests/Worker/FiberWorkerTest.php:518 and tests/Worker/WorkerTest.php:490.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertCount(0, $worker->getFailedTasks());
    }
    /**
     * @throws Throwable {@see TaskListInterface::add()}

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertCount(1, $worker->getFailedTasks());
The next 41 lines appear both in tests/Worker/FiberWorkerTest.php:569 and tests/Worker/WorkerTest.php:538.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertInstanceOf(FailedTask::class, $worker->getFailedTasks()->get('foo.failed'));
        self::assertNotNull($worker->getLastExecutedTask());
        self::assertSame($validTask, $worker->getLastExecutedTask());
    }

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertCount(0, $worker->getFailedTasks());
The next 30 lines appear both in tests/Worker/FiberWorkerTest.php:617 and tests/Worker/WorkerTest.php:583.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertSame($task, $worker->getLastExecutedTask());
    }
    /**
     * @throws Throwable {@see TaskListInterface::add()}

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertSame(1, $worker->getConfiguration()->getExecutedTasksCount());
The next 37 lines appear both in tests/Worker/FiberWorkerTest.php:661 and tests/Worker/WorkerTest.php:624.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertInstanceOf(NullTask::class, $worker->getLastExecutedTask());
        $task = $scheduler->getTasks()->get('foo');
        self::assertFalse($task->isSingleRun());

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertSame(0, $worker->getConfiguration()->getExecutedTasksCount());
The next 47 lines appear both in tests/Worker/FiberWorkerTest.php:712 and tests/Worker/WorkerTest.php:672.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertNull($worker->getLastExecutedTask());
    }
    /**
     * @throws Throwable {@see TaskListInterface::add()}

    }
    /**
     * @throws Throwable {@see TaskListInterface::add()}
     */
    public function testTaskCanBeExecutedAndTheWorkerCanReturnTheLastExecutedTask(): void
The next 29 lines appear both in tests/Worker/FiberWorkerTest.php:719 and tests/Worker/FiberWorkerTest.php:1062.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
    {
        $task = new NullTask('foo');
        $logger = $this->createMock(LoggerInterface::class);
        $logger->expects(self::never())->method('info');

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertSame($task, $worker->getLastExecutedTask());
The next 40 lines appear both in tests/Worker/FiberWorkerTest.php:755 and tests/Worker/WorkerTest.php:712.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
    }
    /**
     * @throws Throwable {@see TaskListInterface::add()}
     */

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertSame($shellTask, $worker->getLastExecutedTask());
The next 34 lines appear both in tests/Worker/FiberWorkerTest.php:804 and tests/Worker/WorkerTest.php:758.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
    }
    /**
     * @throws Throwable {@see TaskListInterface::add()}
     */

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        $failedTasks = $worker->getFailedTasks();
The next 48 lines appear both in tests/Worker/FiberWorkerTest.php:846 and tests/Worker/WorkerTest.php:797.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertCount(1, $failedTasks);
        $failedTask = $failedTasks->get('foo.failed');
        self::assertInstanceOf(FailedTask::class, $failedTask);
        self::assertNotEmpty($worker->getFailedTasks());

    }
    /**
     * @throws Throwable {@see TaskListInterface::add()}
     */
    public function testTaskCanBeExecutedWithoutBeforeExecutionNotificationAndNotifier(): void
The next 49 lines appear both in tests/Worker/FiberWorkerTest.php:860 and tests/Worker/FiberWorkerTest.php:961.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
    {
        $task = new NullTask('foo');
        $logger = $this->createMock(LoggerInterface::class);
        $logger->expects(self::never())->method('info');

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertSame($task, $worker->getLastExecutedTask());
The next 58 lines appear both in tests/Worker/FiberWorkerTest.php:901 and tests/Worker/WorkerTest.php:849.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertCount(0, $worker->getFailedTasks());
    }
    /**
     * @throws Throwable {@see TaskListInterface::add()}

        ]);
        $logger = $this->createMock(LoggerInterface::class);
        $logger->expects(self::never())->method('info');
        $notifier = $this->createMock(NotifierInterface::class);
The next 28 lines appear both in tests/Worker/FiberWorkerTest.php:920 and tests/Worker/FiberWorkerTest.php:1021.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        $notifier->expects(self::once())->method('send')->with(self::equalTo($notification), $recipient);
        $tracker = $this->createMock(TaskExecutionTrackerInterface::class);
        $tracker->expects(self::once())->method('startTracking');
        $tracker->expects(self::once())->method('endTracking');

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertSame($task, $worker->getLastExecutedTask());
The next 53 lines appear both in tests/Worker/FiberWorkerTest.php:954 and tests/Worker/WorkerTest.php:899.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertCount(0, $worker->getFailedTasks());
    }
    /**
     * @throws Throwable

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertSame($task, $worker->getLastExecutedTask());
The next 47 lines appear both in tests/Worker/FiberWorkerTest.php:1002 and tests/Worker/WorkerTest.php:944.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertCount(0, $worker->getFailedTasks());
    }
    /**
     * @throws Throwable

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertSame($task, $worker->getLastExecutedTask());
The next 36 lines appear both in tests/Worker/FiberWorkerTest.php:1055 and tests/Worker/WorkerTest.php:994.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertCount(0, $worker->getFailedTasks());
    }
    /**
     * @throws Throwable

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertSame($task, $worker->getLastExecutedTask());
The next 37 lines appear both in tests/Worker/FiberWorkerTest.php:1099 and tests/Worker/WorkerTest.php:1035.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
    }
    /**
     * @throws Throwable
     */

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertSame($task, $worker->getLastExecutedTask());
The next 51 lines appear both in tests/Worker/FiberWorkerTest.php:1151 and tests/Worker/WorkerTest.php:1084.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
    }
    /**
     * @throws Throwable
     */

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertNull($worker->getLastExecutedTask());
The next 38 lines appear both in tests/Worker/FiberWorkerTest.php:1203 and tests/Worker/WorkerTest.php:1134.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertCount(1, $worker->getFailedTasks());
        $failedTask = $worker->getFailedTasks()->get('foo.failed');
        self::assertInstanceOf(FailedTask::class, $failedTask);
        self::assertSame($task, $failedTask->getTask());

            new TaskLockBagMiddleware($lockFactory),
        ]), $eventDispatcher, $lockFactory, $logger);
        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration, $task);
The next 39 lines appear both in tests/Worker/FiberWorkerTest.php:1248 and tests/Worker/WorkerTest.php:1176.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Fri, 15 Apr 2022 08:09:00 +0000 by Guillaume Loulier
                    
        self::assertCount(0, $worker->getFailedTasks());
        self::assertSame($task, $worker->getLastExecutedTask());
    }

            new TaskLockBagMiddleware($lockFactory),
        ]), $eventDispatcher, $lockFactory, $logger);
        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration, $task);
The next 54 lines appear both in tests/Worker/FiberWorkerTest.php:1294 and tests/Worker/WorkerTest.php:1220.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Fri, 15 Apr 2022 08:09:00 +0000 by Guillaume Loulier
                    
        self::assertCount(1, $worker->getFailedTasks());
        self::assertNull($worker->getLastExecutedTask());
    }

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertNull($worker->getLastExecutedTask());
The next 34 lines appear both in tests/Worker/FiberWorkerTest.php:1358 and tests/Worker/WorkerTest.php:1281.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
    }
    /**
     * @throws Throwable
     */

    }
    /**
     * @throws Throwable
     */
    public function testWorkerCanExecuteChainedTasks(): void
The next 36 lines appear both in tests/Worker/FiberWorkerTest.php:1364 and tests/Worker/FiberWorkerTest.php:1427.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
    {
        $chainedTask = new ChainedTask(
            'foo',
            new ShellTask('chained_foo', ['ls', '-al']),
            new ShellTask('chained_bar', ['ls', '-al'])

            new TaskLockBagMiddleware($lockFactory),
        ]), $eventDispatcher, $lockFactory, $logger);
        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
The next 30 lines appear both in tests/Worker/FiberWorkerTest.php:1400 and tests/Worker/FiberWorkerTest.php:1464.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Fri, 15 Apr 2022 08:09:00 +0000 by Guillaume Loulier
                    
        self::assertSame($shellTask, $worker->getLastExecutedTask());
        self::assertSame(TaskInterface::SUCCEED, $chainedTask->getExecutionState());
        self::assertNotNull($chainedTask->getExecutionStartTime());
        self::assertNotNull($chainedTask->getExecutionEndTime());

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertSame($shellTask, $worker->getLastExecutedTask());
The next 57 lines appear both in tests/Worker/FiberWorkerTest.php:1402 and tests/Worker/WorkerTest.php:1321.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertSame(TaskInterface::SUCCEED, $chainedTask->getExecutionState());
        self::assertNotNull($chainedTask->getExecutionStartTime());
        self::assertNotNull($chainedTask->getExecutionEndTime());
        $chainedFooTask = $chainedTask->getTask('chained_foo');

            new TaskLockBagMiddleware($lockFactory),
        ]), $eventDispatcher, $lockFactory, $logger);
        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $configuration->mustRetrieveTasksLazily(true);
The next 58 lines appear both in tests/Worker/FiberWorkerTest.php:1463 and tests/Worker/WorkerTest.php:1380.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        $worker->execute($configuration);
        self::assertSame($shellTask, $worker->getLastExecutedTask());
        self::assertSame(TaskInterface::SUCCEED, $chainedTask->getExecutionState());
        self::assertNotNull($chainedTask->getExecutionStartTime());

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertSame($task, $worker->getLastExecutedTask());
The next 34 lines appear both in tests/Worker/FiberWorkerTest.php:1530 and tests/Worker/WorkerTest.php:1446.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertNull($task->getAccessLockBag());
        self::assertFalse($worker->getConfiguration()->isRunning());
        self::assertSame(1, $worker->getConfiguration()->getExecutedTasksCount());
    }

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertCount(0, $worker->getFailedTasks());
The next 26 lines appear both in tests/Worker/FiberWorkerTest.php:1575 and tests/Worker/WorkerTest.php:1489.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertSame($task, $worker->getLastExecutedTask());
        self::assertFalse($worker->getConfiguration()->isRunning());
        self::assertSame(1, $worker->getConfiguration()->getExecutedTasksCount());
    }

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertCount(0, $worker->getFailedTasks());
The next 28 lines appear both in tests/Worker/FiberWorkerTest.php:1612 and tests/Worker/WorkerTest.php:1524.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertNull($worker->getLastExecutedTask());
        self::assertTrue($worker->getConfiguration()->shouldStop());
        self::assertFalse($worker->getConfiguration()->isRunning());
        self::assertSame(0, $worker->getConfiguration()->getExecutedTasksCount());
    }

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertCount(1, $worker->getFailedTasks());
The next 27 lines appear both in tests/Worker/FiberWorkerTest.php:1650 and tests/Worker/WorkerTest.php:1560.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertNull($worker->getLastExecutedTask());
        self::assertFalse($worker->getConfiguration()->isRunning());
        self::assertSame(0, $worker->getConfiguration()->getExecutedTasksCount());
    }

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertCount(0, $worker->getFailedTasks());
The next 46 lines appear both in tests/Worker/FiberWorkerTest.php:1696 and tests/Worker/WorkerTest.php:1602.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertFalse($worker->getConfiguration()->isRunning());
        self::assertNull($worker->getLastExecutedTask());
        self::assertSame(0, $worker->getConfiguration()->getExecutedTasksCount());
        self::assertSame(0, $worker->getConfiguration()->getExecutedTasksCount());
    }

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertCount(0, $worker->getFailedTasks());
The next 38 lines appear both in tests/Worker/FiberWorkerTest.php:1754 and tests/Worker/WorkerTest.php:1657.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertSame(1, $worker->getConfiguration()->getExecutedTasksCount());
        self::assertFalse($worker->isRunning());
    }
    /**

        $configuration = WorkerConfiguration::create();
        $configuration->setExecutionPolicy('fiber');
        $worker->execute($configuration);
        self::assertFalse($worker->isRunning());
The next 25 lines appear both in tests/Worker/FiberWorkerTest.php:1805 and tests/Worker/WorkerTest.php:1706.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        self::assertCount(0, $worker->getFailedTasks());
        self::assertTrue($worker->getConfiguration()->shouldStop());
    }
    /**

    }
    /**
     * @throws Throwable {@see WorkerInterface::preempt()}
     */
    public function testWorkerCanPreempt(): void
The next 30 lines appear both in tests/Worker/FiberWorkerTest.php:1813 and tests/Worker/FiberWorkerTest.php:1862.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
    {
        $logger = $this->createMock(LoggerInterface::class);
        $tracker = $this->createMock(TaskExecutionTrackerInterface::class);
        $transport = new InMemoryTransport(new InMemoryConfiguration(), new SchedulePolicyOrchestrator([

            new TaskUpdateMiddleware($transport),
            new TaskLockBagMiddleware($lockFactory),
        ]), new EventDispatcher(), $lockFactory, $logger);
        $worker->getConfiguration()->setExecutionPolicy('fiber');
        $barTask = new NullTask('bar');
The next 41 lines appear both in tests/Worker/FiberWorkerTest.php:1838 and tests/Worker/WorkerTest.php:1737.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 12 Apr 2022 14:37:55 +0000 by Guillaume Loulier
                    
        $randomTask = new NullTask('random');
        $preemptList = new TaskList([
            new NullTask('foo'),
            $barTask,

        $logger = $this->createMock(LoggerInterface::class);
        $logger->expects(self::never())->method('info');
        $tracker = $this->createMock(TaskExecutionTrackerInterface::class);
        $tracker->expects(self::never())->method('startTracking')->with(self::equalTo($task));
        $tracker->expects(self::never())->method('endTracking')->with(self::equalTo($task));
The next 26 lines appear both in tests/Worker/WorkerTest.php:372 and tests/Worker/WorkerTest.php:465.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Tue, 23 Feb 2021 06:49:53 +0000 by Guillaume Loulier
                    
        $transport = new InMemoryTransport(new InMemoryConfiguration(), new SchedulePolicyOrchestrator([
            new FirstInFirstOutPolicy(),
        ]));

        $tracker = $this->createMock(TaskExecutionTrackerInterface::class);
        $tracker->expects(self::never())->method('startTracking')->with(self::equalTo($task));
        $tracker->expects(self::never())->method('endTracking')->with(self::equalTo($task));
        $transport = new InMemoryTransport(new InMemoryConfiguration(), new SchedulePolicyOrchestrator([
The next 24 lines appear both in tests/Worker/WorkerTest.php:374 and tests/Worker/WorkerTest.php:560.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Wed, 27 Apr 2022 03:35:14 +0000 by Guillaume Loulier
                    
            new FirstInFirstOutPolicy(),
        ]));
        $scheduler = new Scheduler('UTC', $transport, new SchedulerMiddlewareStack(), new EventDispatcher());
        $scheduler->schedule($task);

        $scheduler->schedule($validTask);
        $eventDispatcher = new EventDispatcher();
        $eventDispatcher->addSubscriber(new StopWorkerOnTaskLimitSubscriber(2));
        $lockFactory = new LockFactory(new InMemoryStore());
The next 23 lines appear both in tests/Worker/WorkerTest.php:432 and tests/Worker/WorkerTest.php:525.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Fri, 13 Aug 2021 06:40:49 +0000 by Guillaume Loulier
                    
        $worker = new Worker($scheduler, new RunnerRegistry([
            new NullTaskRunner(),
        ]), new ExecutionPolicyRegistry([
            new DefaultPolicy(),

    }
    /**
     * @throws Throwable {@see WorkerInterface::preempt()}
     */
    public function testWorkerCanPreempt(): void
The next 28 lines appear both in tests/Worker/WorkerTest.php:1714 and tests/Worker/WorkerTest.php:1761.
Time to fix: about 4 hours
Read doc
                Open Issue
             Permalink

                                    Last edited Thu, 14 Oct 2021 10:22:35 +0000 by Guillaume Loulier
                    
    {
        $logger = $this->createMock(LoggerInterface::class);
        $tracker = $this->createMock(TaskExecutionTrackerInterface::class);
        $transport = new InMemoryTransport(new InMemoryConfiguration(), new SchedulePolicyOrchestrator([