(name)
| 413 | if hasattr(method, MAGIC_ATTR): |
| 414 | |
| 415 | def generate_function(name): |
| 416 | |
| 417 | def func(self, *args, **kwargs): |
| 418 | # dispatch to the actual worker |
| 419 | return getattr(self.worker_dict[key], name)(*args, **kwargs) |
| 420 | |
| 421 | return func |
| 422 | |
| 423 | func = generate_function(method_name) |
| 424 | # pass MAGIC_ATTR for outer worker group |
no outgoing calls
no test coverage detected