(self, data)
| 884 | raise TaskTimeout('timeout %ss' % self.timeout) |
| 885 | |
| 886 | def extend_data(self, data): |
| 887 | if data is None or data == (): |
| 888 | return |
| 889 | |
| 890 | if isinstance(data, tuple): |
| 891 | self.args += data |
| 892 | elif isinstance(data, dict): |
| 893 | # XXX: alternate would be self.kwargs.update(data), but this will |
| 894 | # stomp on user-provided parameters. |
| 895 | for key, value in data.items(): |
| 896 | self.kwargs.setdefault(key, value) |
| 897 | else: |
| 898 | self.args = self.args + (data,) |
| 899 | |
| 900 | def then(self, task, *args, **kwargs): |
| 901 | if self.on_complete: |
no outgoing calls
no test coverage detected