| 1037 | return self.func(*args, **kwargs) |
| 1038 | |
| 1039 | def s(self, *args, **kwargs): |
| 1040 | eta = kwargs.pop('eta', None) |
| 1041 | delay = kwargs.pop('delay', None) |
| 1042 | if delay is not None and isinstance(delay, datetime.timedelta): |
| 1043 | delay = delay.total_seconds() |
| 1044 | if eta is not None or delay is not None: |
| 1045 | eta = normalize_time(eta, delay, self.huey.utc) |
| 1046 | |
| 1047 | return self.task_class(args, kwargs, |
| 1048 | eta=eta, |
| 1049 | retries=kwargs.pop('retries', None), |
| 1050 | retry_delay=kwargs.pop('retry_delay', None), |
| 1051 | priority=kwargs.pop('priority', None), |
| 1052 | expires=kwargs.pop('expires', None), |
| 1053 | timeout=kwargs.pop('timeout', None)) |
| 1054 | |
| 1055 | |
| 1056 | class TaskLock(object): |