external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

copy postgres' error_severiry implementation

background-job-details
Nils Dijk 2022-08-10 00:53:37 +02:00 committed by Jelte Fennema
parent 414dbf9070
commit 160385ca2f
1 changed files with 18 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/backend/distributed/utils/background_jobs.c
View File

@ -350,17 +350,12 @@ CitusBackgroundTaskMonitorMain(Datum arg)
} }
/* static const char *
* bgw_generate_returned_message - error_severity(int elevel)
* generates the message to be inserted into the job_run_details table
* first part is comming from error_severity (elog.c)
*/
static void
bgw_generate_returned_message(StringInfoData *display_msg, ErrorData edata)
{ {
const char *prefix = NULL; const char *prefix;
switch (edata.elevel) switch (elevel)
{ {
case DEBUG1: case DEBUG1:
case DEBUG2: case DEBUG2:
@ -392,6 +387,7 @@ bgw_generate_returned_message(StringInfoData *display_msg, ErrorData edata)
} }
case WARNING: case WARNING:
case WARNING_CLIENT_ONLY:
{ {
prefix = gettext_noop("WARNING"); prefix = gettext_noop("WARNING");
break; break;
@ -422,6 +418,19 @@ bgw_generate_returned_message(StringInfoData *display_msg, ErrorData edata)
} }
} }
return prefix;
}
/*
* bgw_generate_returned_message -
* generates the message to be inserted into the job_run_details table
* first part is comming from error_severity (elog.c)
*/
static void
bgw_generate_returned_message(StringInfoData *display_msg, ErrorData edata)
{
const char *prefix = error_severity(edata.elevel);
appendStringInfo(display_msg, "%s: %s", prefix, edata.message); appendStringInfo(display_msg, "%s: %s", prefix, edata.message);
if (edata.detail != NULL) if (edata.detail != NULL)
{ {