<commit_before><?php

namespace TaskQueue\Log;

use TaskQueue\Queue\QueueInterface;
use TaskQueue\Task\TaskInterface;

class LoggableQueue implements QueueInterface
{
    /**
     * @var \TaskQueue\Queue\QueueInterface
     */
    protected $queue;

    /**
     * @var \TaskQueue\Log\LoggerInterface
     */
    protected $logger;

    /**
     * Constructor.
     *
     * @param \TaskQueue\Queue\QueueInterface $queue
     * @param \TaskQueue\Log\LoggerInterface $logger
     */
    public function __construct(QueueInterface $queue, LoggerInterface $logger)
    {
        $this->queue = $queue;
        $this->logger = $logger;
    }

    /**
     * @return \TaskQueue\Queue\QueueInterface
     */
    public function getQueue()
    {
        return $this->queue;
    }

    /**
     * @return Log\LoggerInterface
     */
    public function getLogger()
    {
        return $this->logger;
    }

    /**
     * @see QueueInterface::push()
     */
    public function push(TaskInterface $task)
    {
        try {
            $this->queue->push($task);
        } catch (\Exception $e) {
            $this->logger->err(sprintf('Unable to push task %s: %s.', $task, $e->getMessage()));
            throw $e;<commit_msg>fixed PHPDoc<commit_after><?php

namespace TaskQueue\Log;

use TaskQueue\Queue\QueueInterface;
use TaskQueue\Task\TaskInterface;

class LoggableQueue implements QueueInterface
{
    /**
     * @var \TaskQueue\Queue\QueueInterface
     */
    protected $queue;

    /**
     * @var \TaskQueue\Log\LoggerInterface
     */
    protected $logger;

    /**
     * Constructor.
     *
     * @param \TaskQueue\Queue\QueueInterface $queue
     * @param \TaskQueue\Log\LoggerInterface $logger
     */
    public function __construct(QueueInterface $queue, LoggerInterface $logger)
    {
        $this->queue = $queue;
        $this->logger = $logger;
    }

    /**
     * @return \TaskQueue\Queue\QueueInterface
     */
    public function getQueue()
    {
        return $this->queue;
    }

    /**
     * @return \TaskQueue\Log\LoggerInterface
     */
    public function getLogger()
    {
        return $this->logger;
    }

    /**
     * @see QueueInterface::push()
     */
    public function push(TaskInterface $task)
    {
        try {
            $this->queue->push($task);
        } catch (\Exception $e) {
            $this->logger->err(sprintf('Unable to push task %s: %s.', $task, $e->getMessage()));
            throw $e;
{'fraction_non_alphanumeric': 0.13784665579119088, 'fraction_numerical': 0.0, 'mean_word_length': 2.1129441624365484, 'pattern_counts': {'":': 0, '<': 5, '<?xml version=': 0, '>': 21, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '3934776', 'n_tokens_mistral': 730, 'n_tokens_neox': 724, 'n_words': 142}