(self, **args)
| 279 | self._is_async = is_async |
| 280 | |
| 281 | def set_args(self, **args): |
| 282 | assert not self._closed |
| 283 | args2 = args.copy() |
| 284 | args_mask = args2.pop('mask') |
| 285 | if self._cur_args: |
| 286 | _cur_args = self._cur_args.copy() |
| 287 | cur_args_mask = _cur_args.pop('mask') |
| 288 | else: |
| 289 | _cur_args = self._cur_args |
| 290 | # if args != self._cur_args: |
| 291 | if args2 != _cur_args: |
| 292 | if self._is_async: |
| 293 | self._set_args_async(**args) |
| 294 | else: |
| 295 | self._set_args_sync(**args) |
| 296 | self._cur_args = args |
| 297 | |
| 298 | def _set_args_async(self, **args): |
| 299 | if self._process is None: |
no test coverage detected