in go/utils.go [680:707]
func isQueryTimeOut(startOfStartQueryExecution time.Time, queryType string, serviceLimitOverride *ServiceLimitOverride) bool {
ddlQueryTimeout := DDLQueryTimeout
dmlQueryTimeout := DMLQueryTimeout
if serviceLimitOverride != nil {
if serviceLimitOverride.GetDDLQueryTimeout() > 0 {
ddlQueryTimeout = serviceLimitOverride.GetDDLQueryTimeout()
}
if serviceLimitOverride.GetDMLQueryTimeout() > 0 {
dmlQueryTimeout = serviceLimitOverride.GetDMLQueryTimeout()
}
}
switch queryType {
case "DDL":
return time.Since(startOfStartQueryExecution) >
time.Duration(ddlQueryTimeout)*time.Second
case "DML":
return time.Since(startOfStartQueryExecution) >
time.Duration(dmlQueryTimeout)*time.Second
case "UTILITY":
return time.Since(startOfStartQueryExecution) >
time.Duration(dmlQueryTimeout)*time.Second
case "TIMEOUT_NOW":
return true
default:
return time.Since(startOfStartQueryExecution) >
time.Duration(ddlQueryTimeout)*time.Second
}
}