@@ -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'][] = [ |