bricev / JobQueue

example/Job/DummyJob.php

Spacing +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
     {
         // do dummy stuff...
         $duration = ceil($this->getParameter('duration', 3));
-        for ($i=0; $i<$duration; $i++) {
+        for ($i = 0; $i < $duration; $i++) {
             $this->setTaskProgress($i / $duration);
             sleep(1);
         }

src/Libcast/JobQueue/Console/Command/EditTaskCommand.php

Spacing +5 added lines, -5 removed lines

@@ -24,10 +24,10 @@ 
         $this
             ->setName('task:edit')
             ->setDescription('Edit a Task')
-            ->addArgument('id',           InputArgument::REQUIRED,     'Task Id')
+            ->addArgument('id', InputArgument::REQUIRED, 'Task Id')
             ->addOption('parent-id', 'i', InputOption::VALUE_OPTIONAL, 'Set parent Id (Eg. 123)', null)
-            ->addOption('profile',   'p', InputOption::VALUE_OPTIONAL, 'Set profile (eg. "high-cpu")', null)
-            ->addOption('status',    's', InputOption::VALUE_OPTIONAL, 'Set status (pending|waiting|running|success|failed|finished)', null)
+            ->addOption('profile', 'p', InputOption::VALUE_OPTIONAL, 'Set profile (eg. "high-cpu")', null)
+            ->addOption('status', 's', InputOption::VALUE_OPTIONAL, 'Set status (pending|waiting|running|success|failed|finished)', null)
         ;
 
         parent::configure();
@@ -71,8 +71,8 @@ 
         }
 
         $table = new OutputTable;
-        $table->addColumn('Key',    15, OutputTable::RIGHT);
-        $table->addColumn('Value',  25, OutputTable::LEFT);
+        $table->addColumn('Key', 15, OutputTable::RIGHT);
+        $table->addColumn('Value', 25, OutputTable::LEFT);
 
         $table->addRow([
             'Key'   => 'Id',

src/Libcast/JobQueue/Console/Command/AddTaskCommand.php

Spacing +4 added lines, -4 removed lines

@@ -25,11 +25,11 @@
         $this
             ->setName('task:add')
             ->setDescription('Add a Task')
-            ->addArgument('name',         InputArgument::REQUIRED,     'Name of the Task')
-            ->addArgument('profile',      InputArgument::REQUIRED,     'Profile of the Task')
-            ->addArgument('job',          InputArgument::REQUIRED,     'Job class namespace')
+            ->addArgument('name', InputArgument::REQUIRED, 'Name of the Task')
+            ->addArgument('profile', InputArgument::REQUIRED, 'Profile of the Task')
+            ->addArgument('job', InputArgument::REQUIRED, 'Job class namespace')
             ->addOption('parent-id', 'i', InputOption::VALUE_OPTIONAL, 'Set parent Id (Eg. 123)', null)
-            ->addOption('status',    's', InputOption::VALUE_REQUIRED, 'Set status (Eg. waiting)', Task::STATUS_PENDING)
+            ->addOption('status', 's', InputOption::VALUE_REQUIRED, 'Set status (Eg. waiting)', Task::STATUS_PENDING)
             ->addOption('parameter', 'p', InputOption::VALUE_IS_ARRAY | InputOption::VALUE_OPTIONAL, 'Add a parameter (Eg. --parameter="bitrate: 1024")', [])
         ;
 

src/Libcast/JobQueue/Console/Command/ShowQueueCommand.php

Spacing +14 added lines, -14 removed lines

@@ -25,10 +25,10 @@ 
         $this
             ->setName('queue:show')
             ->setDescription('List tasks from the queue')
-            ->addOption('profile',    'p', InputOption::VALUE_OPTIONAL, 'Filter by profile (eg. "high-cpu")', null)
-            ->addOption('status',     's', InputOption::VALUE_OPTIONAL, 'Filter by status (pending|waiting|running|success|failed|finished)', null)
+            ->addOption('profile', 'p', InputOption::VALUE_OPTIONAL, 'Filter by profile (eg. "high-cpu")', null)
+            ->addOption('status', 's', InputOption::VALUE_OPTIONAL, 'Filter by status (pending|waiting|running|success|failed|finished)', null)
             ->addOption('sort-order', 'o', InputOption::VALUE_OPTIONAL, 'Sort by order asc|desc', 'asc')
-            ->addOption('follow',     'f', InputOption::VALUE_NONE,     'Refresh screen, display Queue Tasks in real time')
+            ->addOption('follow', 'f', InputOption::VALUE_NONE, 'Refresh screen, display Queue Tasks in real time')
         ;
 
     }
@@ -87,13 +87,13 @@ 
 
         if ($count) {
             $table = new OutputTable;
-            $table->addColumn('Id',      5,  OutputTable::RIGHT);
-            $table->addColumn('Parent',  5,  OutputTable::RIGHT);
+            $table->addColumn('Id', 5, OutputTable::RIGHT);
+            $table->addColumn('Parent', 5, OutputTable::RIGHT);
             $table->addColumn('Profile', 10, OutputTable::RIGHT);
-            $table->addColumn('Name',    14, OutputTable::LEFT);
-            $table->addColumn('Worker',  20, OutputTable::LEFT);
-            $table->addColumn('Status',  8,  OutputTable::LEFT);
-            $table->addColumn('%',       4,  OutputTable::RIGHT);
+            $table->addColumn('Name', 14, OutputTable::LEFT);
+            $table->addColumn('Worker', 20, OutputTable::LEFT);
+            $table->addColumn('Status', 8, OutputTable::LEFT);
+            $table->addColumn('%', 4, OutputTable::RIGHT);
 
             foreach ($tasks as $task) { /* @var $task \Libcast\JobQueue\Task */
                 $table->addRow([
@@ -107,11 +107,11 @@ 
                 ], $task->getStatus());
             }
 
-            $output->getFormatter()->setStyle('pending',  new OutputFormatterStyle('white'));
-            $output->getFormatter()->setStyle('waiting',  new OutputFormatterStyle('blue'));
-            $output->getFormatter()->setStyle('running',  new OutputFormatterStyle('blue', 'cyan'));
-            $output->getFormatter()->setStyle('failed',   new OutputFormatterStyle('red'));
-            $output->getFormatter()->setStyle('success',  new OutputFormatterStyle('green'));
+            $output->getFormatter()->setStyle('pending', new OutputFormatterStyle('white'));
+            $output->getFormatter()->setStyle('waiting', new OutputFormatterStyle('blue'));
+            $output->getFormatter()->setStyle('running', new OutputFormatterStyle('blue', 'cyan'));
+            $output->getFormatter()->setStyle('failed', new OutputFormatterStyle('red'));
+            $output->getFormatter()->setStyle('success', new OutputFormatterStyle('green'));
             $output->getFormatter()->setStyle('finished', new OutputFormatterStyle('green', null, ['bold']));
 
             $this->addLine($table->getTable(true));

src/Libcast/JobQueue/Console/OutputTable.php

Indentation +5 added lines, -5 removed lines

@@ -37,7 +37,7 @@ 
 
     protected function countColumns()
     {
-      return count($this->columns);
+        return count($this->columns);
     }
 
     public function addRow(array $cells, $style = null)
@@ -97,7 +97,7 @@ 
             $strings[] = $this->getRow($i, $with_style);
 
             if ($i < 0) {
-              $strings[] = $this->getLine();
+                $strings[] = $this->getLine();
             }
         }
 
@@ -145,7 +145,7 @@ 
     protected function getRowStyle($i)
     {
         if (!isset($this->row_style[$i]) || $this->row_style[$i] === '#') {
-          return null;
+            return null;
         }
 
         return $this->row_style[$i];
@@ -154,7 +154,7 @@ 
     protected function getCell($column, $row)
     {
         if (!isset($this->rows[$row][$column])) {
-          throw new CommandException("Their is no value for column '$column', row '$row'");
+            throw new CommandException("Their is no value for column '$column', row '$row'");
         }
 
         return $this->rows[$row][$column];
@@ -165,7 +165,7 @@ 
         $count = 0;
 
         foreach ($this->getColumnTitles() as $title) {
-          $count += $this->getColumnWidth($title);
+            $count += $this->getColumnWidth($title);
         }
 
         $count += $this->countColumns() * 3;

src/Libcast/JobQueue/LoggerTrait.php

Spacing +2 added lines, -2 removed lines

@@ -44,7 +44,7 @@ 
      */
     public function setLoggerWorker(Worker $worker)
     {
-        $this->logger->pushProcessor(function ($record) use ($worker) {
+        $this->logger->pushProcessor(function($record) use ($worker) {
             $record['context']['tags']['worker_profile'] = $worker->getProfile();
             $record['context']['tags']['worker_name'] = $worker->getName();
 
@@ -58,7 +58,7 @@ 
      */
     public function setLoggerTask(Task $task)
     {
-        $this->logger->pushProcessor(function ($record) use ($task) {
+        $this->logger->pushProcessor(function($record) use ($task) {
             $record['context']['tags']['task_id'] = $task->getId();
             $record['context']['tags']['task_name'] = $task->getName();
 

src/Libcast/JobQueue/Queue/RedisQueue.php

Spacing +3 added lines, -4 removed lines

@@ -79,8 +79,7 @@ 
                 foreach ($competitor_ids as $rank => $id) {
                     // Collect ancestor id if exists
                     $competitor_id = ($competitor = $this->getTask($id)) ?
-                            $competitor->getRootId() :
-                            $id;
+                            $competitor->getRootId() : $id;
 
                     // Avoid having two competitors with the same root ancestor
                     if (in_array($competitor_id, $competitor_roots)) {
@@ -344,8 +343,8 @@ 
             $keys = $this->getClient()->keys(self::key('tasks:*:*'));
 
             // Hide `finished` Tasks when listing everything
-            $keys = array_filter($keys, function ($value) {
-                return !preg_match('/^'. self::PREFIX . ':tasks:([^:]+):' . Task::STATUS_FINISHED . '$/', $value);
+            $keys = array_filter($keys, function($value) {
+                return !preg_match('/^' . self::PREFIX . ':tasks:([^:]+):' . Task::STATUS_FINISHED . '$/', $value);
             });
         } elseif (!$filter_by_profile) {
             $keys = $this->getClient()->keys(self::key("tasks:*:$filter_by_status"));

Braces +3 added lines, -1 removed lines

@@ -447,10 +447,12 @@
 
         // recursively add children's progressions
         $progress = $task->getProgress();
-        foreach ($task->getChildren() as $child) /* @var $child Task */
+        foreach ($task->getChildren() as $child) {
+            /* @var $child Task */
         {
             $progress += $this->getProgress($child, false);
         }
+        }
 
         $global = $progress / ($task->countChildren() + 1);