From 62ef1c353628f115930270aaa150bf881d9db4ac Mon Sep 17 00:00:00 2001 From: Mehmet Yilmaz Date: Fri, 4 Apr 2025 11:09:32 +0000 Subject: [PATCH] Replace job cancellation call with DirectFunctionCall for improved error handling --- src/backend/distributed/utils/background_jobs.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/backend/distributed/utils/background_jobs.c b/src/backend/distributed/utils/background_jobs.c index cfa5baca5..b63efb5e6 100644 --- a/src/backend/distributed/utils/background_jobs.c +++ b/src/backend/distributed/utils/background_jobs.c @@ -343,7 +343,7 @@ citus_job_wait_internal(int64 jobid, BackgroundJobStatus *desiredStatus) MemoryContextSwitchTo(TopMemoryContext); /* Attempt to cancel the job; if it's already in a terminal state, that's okay. */ - citus_cancel_job(jobid); + (void) DirectFunctionCall1(citus_job_cancel, Int64GetDatum(jobid)); /* Re-throw the original error so Postgres knows this statement was canceled. */ PG_RE_THROW();