summaryrefslogtreecommitdiff
path: root/pkg/worker/sync_worker.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-02-24 14:16:59 +0300
committerGitHub <[email protected]>2021-02-24 14:16:59 +0300
commitb3cb0cd2428f1bfdd959ea8f3461e2992b6acdb2 (patch)
tree0d226eb8ad9730ede1f7cd80b5f7b44d1fb23b0a /pkg/worker/sync_worker.go
parent3c5a85bf8a0d1c8b8f8f71c215f75b338c4e7510 (diff)
parentcaea9cb452fda97a9496bc33190c95fbc27e54c3 (diff)
Merge pull request #551 from spiral/rc.4-releasev2.0.0-RC.4
âš¡ release(RC.4): Release RC.4
Diffstat (limited to 'pkg/worker/sync_worker.go')
-rwxr-xr-xpkg/worker/sync_worker.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/pkg/worker/sync_worker.go b/pkg/worker/sync_worker.go
index 82a5462a..ac987c14 100755
--- a/pkg/worker/sync_worker.go
+++ b/pkg/worker/sync_worker.go
@@ -63,7 +63,7 @@ type wexec struct {
}
// Exec payload without TTL timeout.
-func (tw *SyncWorkerImpl) ExecWithTimeout(ctx context.Context, p payload.Payload) (payload.Payload, error) {
+func (tw *SyncWorkerImpl) ExecWithTTL(ctx context.Context, p payload.Payload) (payload.Payload, error) {
const op = errors.Op("sync_worker_exec_worker_with_timeout")
c := make(chan wexec, 1)