aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/test/modules/worker_spi/worker_spi.c9
1 files changed, 9 insertions, 0 deletions
diff --git a/src/test/modules/worker_spi/worker_spi.c b/src/test/modules/worker_spi/worker_spi.c
index 5d81cf45639..1c619d4b189 100644
--- a/src/test/modules/worker_spi/worker_spi.c
+++ b/src/test/modules/worker_spi/worker_spi.c
@@ -173,6 +173,15 @@ worker_spi_main(Datum main_arg)
BackgroundWorkerInitializeConnection(worker_spi_database,
worker_spi_role, flags);
+ /*
+ * Disable parallel query for workers started with BYPASS_ALLOWCONN so as
+ * these don't attempt connections to the database that may not allow
+ * that.
+ */
+ if (flags & BGWORKER_BYPASS_ALLOWCONN)
+ SetConfigOption("max_parallel_workers_per_gather", "0",
+ PGC_USERSET, PGC_S_OVERRIDE);
+
elog(LOG, "%s initialized with %s.%s",
MyBgworkerEntry->bgw_name, table->schema, table->name);
initialize_worker_spi(table);