AbstractScriptInvokeService: tenantId added to the log on script invocation blocked
This commit is contained in:
parent
b36d7c1bcd
commit
cfe79cc445
@ -150,7 +150,7 @@ public abstract class AbstractScriptInvokeService implements ScriptInvokeService
|
|||||||
}
|
}
|
||||||
apiUsageReportClient.ifPresent(client -> client.report(tenantId, customerId, ApiUsageRecordKey.JS_EXEC_COUNT, 1));
|
apiUsageReportClient.ifPresent(client -> client.report(tenantId, customerId, ApiUsageRecordKey.JS_EXEC_COUNT, 1));
|
||||||
pushedMsgs.incrementAndGet();
|
pushedMsgs.incrementAndGet();
|
||||||
log.trace("InvokeScript uuid {} with timeout {}ms", scriptId, getMaxInvokeRequestsTimeout());
|
log.trace("[{}] InvokeScript uuid {} with timeout {}ms", tenantId, scriptId, getMaxInvokeRequestsTimeout());
|
||||||
var task = doInvokeFunction(scriptId, args);
|
var task = doInvokeFunction(scriptId, args);
|
||||||
|
|
||||||
var resultFuture = Futures.transformAsync(task.getResultFuture(), output -> {
|
var resultFuture = Futures.transformAsync(task.getResultFuture(), output -> {
|
||||||
@ -167,7 +167,7 @@ public abstract class AbstractScriptInvokeService implements ScriptInvokeService
|
|||||||
} else {
|
} else {
|
||||||
String message = "Script invocation is blocked due to maximum error count "
|
String message = "Script invocation is blocked due to maximum error count "
|
||||||
+ getMaxErrors() + ", scriptId " + scriptId + "!";
|
+ getMaxErrors() + ", scriptId " + scriptId + "!";
|
||||||
log.warn(message);
|
log.warn("[{}] " + message, tenantId);
|
||||||
return error(message);
|
return error(message);
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user