diff --git i/src/test/modules/worker_spi/t/001_worker_spi.pl w/src/test/modules/worker_spi/t/001_worker_spi.pl index c2938713134..093a038b005 100644 --- i/src/test/modules/worker_spi/t/001_worker_spi.pl +++ w/src/test/modules/worker_spi/t/001_worker_spi.pl @@ -52,6 +52,7 @@ $node->append_conf( shared_preload_libraries = 'worker_spi' worker_spi.database = 'mydb' worker_spi.total_workers = 3 +log_statement=all }); $node->restart; @@ -68,6 +69,9 @@ ok( $node->poll_query_until( # check their existence. my $worker1_pid = $node->safe_psql('mydb', 'SELECT worker_spi_launch(1);'); my $worker2_pid = $node->safe_psql('mydb', 'SELECT worker_spi_launch(2);'); + +sleep(3); + ok( $node->poll_query_until( 'mydb', qq[SELECT datname, count(datname) FROM pg_stat_activity diff --git i/src/test/modules/worker_spi/worker_spi.c w/src/test/modules/worker_spi/worker_spi.c index 903dcddef97..ebd2120ec11 100644 --- i/src/test/modules/worker_spi/worker_spi.c +++ w/src/test/modules/worker_spi/worker_spi.c @@ -120,6 +120,8 @@ initialize_worker_spi(worktable *table) elog(FATAL, "failed to create my schema"); debug_query_string = NULL; /* rest is not statement-specific */ + + pg_usleep(USECS_PER_SEC*1); } SPI_finish(); @@ -127,6 +129,8 @@ initialize_worker_spi(worktable *table) CommitTransactionCommand(); debug_query_string = NULL; pgstat_report_activity(STATE_IDLE, NULL); + + elog(LOG, "done"); } void