@@ -95,7 +95,7 @@ |
||
| 95 | 95 | |
| 96 | 96 | $result = array(); |
| 97 | 97 | |
| 98 | - foreach($tasks as $task) { |
|
| 98 | + foreach ( $tasks as $task ) { |
|
| 99 | 99 | |
| 100 | 100 | if ( empty($task['name']) || empty($task['class']) ) { |
| 101 | 101 | |
@@ -113,7 +113,7 @@ |
||
| 113 | 113 | $this->logger->notice("Task $name ($task) with pid $pid ends in ".$status ? 'success' : 'error'); |
| 114 | 114 | |
| 115 | 115 | return new Result( |
| 116 | - array ( |
|
| 116 | + array( |
|
| 117 | 117 | $pid, |
| 118 | 118 | $name, |
| 119 | 119 | $success, |
@@ -44,7 +44,7 @@ discard block |
||
| 44 | 44 | LoggerInterface $logger, |
| 45 | 45 | Emitter $events, |
| 46 | 46 | $niceness = null |
| 47 | - ){ |
|
| 47 | + ) { |
|
| 48 | 48 | |
| 49 | 49 | // Setup parent Model |
| 50 | 50 | parent::_construct($configuration, $logger); |
@@ -122,7 +122,7 @@ discard block |
||
| 122 | 122 | |
| 123 | 123 | $this->logger->info("Received TERM signal, shutting down process gracefully"); |
| 124 | 124 | |
| 125 | - $this->events->emit( new SignalEvent($signal, $this) ); |
|
| 125 | + $this->events->emit(new SignalEvent($signal, $this)); |
|
| 126 | 126 | |
| 127 | 127 | $this->end(0); |
| 128 | 128 | |
@@ -141,7 +141,7 @@ discard block |
||
| 141 | 141 | |
| 142 | 142 | $this->logger->info("Received TERM signal, shutting down process"); |
| 143 | 143 | |
| 144 | - $this->events->emit( new SignalEvent($signal, $this) ); |
|
| 144 | + $this->events->emit(new SignalEvent($signal, $this)); |
|
| 145 | 145 | |
| 146 | 146 | $this->end(1); |
| 147 | 147 | |
@@ -160,7 +160,7 @@ discard block |
||
| 160 | 160 | |
| 161 | 161 | $this->logger->info("Received $signal signal, firing associated event(s)"); |
| 162 | 162 | |
| 163 | - $this->events->emit( new SignalEvent($signal, $this) ); |
|
| 163 | + $this->events->emit(new SignalEvent($signal, $this)); |
|
| 164 | 164 | |
| 165 | 165 | } |
| 166 | 166 | |