(self)
| 156 | return self |
| 157 | |
| 158 | def kill(self): |
| 159 | STDOUT = subprocess.STDOUT # pylint: disable=no-member |
| 160 | |
| 161 | ps_param = "fax" |
| 162 | if platform.system() == "Darwin": |
| 163 | # BSD ``ps`` doesn't support the ``f`` flag |
| 164 | ps_param = "ax" |
| 165 | |
| 166 | ps_fax = subprocess.check_output(["ps", ps_param], stderr=STDOUT) |
| 167 | |
| 168 | log.debug("Executor process: killing process", command=self.command) |
| 169 | log.debug("Executor process: current processes", ps_fax=ps_fax) |
| 170 | |
| 171 | super().kill() |
| 172 | |
| 173 | ps_fax = subprocess.check_output(["ps", ps_param], stderr=STDOUT) |
| 174 | |
| 175 | log.debug("Executor process: process killed", command=self.command) |
| 176 | log.debug("Executor process: current processes", ps_fax=ps_fax) |
| 177 | |
| 178 | def wait_for(self, wait_for): |
| 179 | while self.check_timeout(): |
no outgoing calls