| 471 | } |
| 472 | |
| 473 | func (s *scope) getTimeoutWithErrMsg() (time.Duration, error) { |
| 474 | var ( |
| 475 | timeout time.Duration |
| 476 | timeoutErrMsg error |
| 477 | ) |
| 478 | if s.user.maxExecutionTime > 0 { |
| 479 | timeout = s.user.maxExecutionTime |
| 480 | timeoutErrMsg = fmt.Errorf("timeout for user %q exceeded: %v", s.user.name, timeout) |
| 481 | } |
| 482 | if timeout == 0 || (s.clusterUser.maxExecutionTime > 0 && s.clusterUser.maxExecutionTime < timeout) { |
| 483 | timeout = s.clusterUser.maxExecutionTime |
| 484 | timeoutErrMsg = fmt.Errorf("timeout for cluster user %q exceeded: %v", s.clusterUser.name, timeout) |
| 485 | } |
| 486 | return timeout, timeoutErrMsg |
| 487 | } |
| 488 | |
| 489 | func (s *scope) maxQueueTime() time.Duration { |
| 490 | d := s.user.maxQueueTime |