@@ -180,8 +180,9 @@ |
||
| 180 | 180 | */ |
| 181 | 181 | public function put(Workflow $workflow) |
| 182 | 182 | { |
| 183 | - if ($this->dispatcher) |
|
| 184 | - $this->dispatcher->dispatch(new CommandEvent($this, ['workflow' => $workflow]), CommandEvent::PUT); |
|
| 183 | + if ($this->dispatcher) { |
|
| 184 | + $this->dispatcher->dispatch(new CommandEvent($this, ['workflow' => $workflow]), CommandEvent::PUT); |
|
| 185 | + } |
|
| 185 | 186 | |
| 186 | 187 | return $this->pheanstalk->put($workflow); |
| 187 | 188 | } |
@@ -92,8 +92,9 @@ |
||
| 92 | 92 | $this->data['tubes'] = []; |
| 93 | 93 | /** @var Tube $tube */ |
| 94 | 94 | foreach ($tubes as $tube) { |
| 95 | - if(strpos($tube->getName(), '@')) |
|
| 96 | - continue; |
|
| 95 | + if(strpos($tube->getName(), '@')) { |
|
| 96 | + continue; |
|
| 97 | + } |
|
| 97 | 98 | // Fetch next ready job and next buried job for this tube |
| 98 | 99 | $stats = $pheanstalk->statsTube($tube); |
| 99 | 100 | $this->data['tubes'][] = [ |