tests: minor fix

Author: gsmolk

tests/ptrack_cluster.py

@@ -46,7 +46,7 @@ def test_ptrack_cluster_on_btree(self):
             idx_ptrack[i]['old_pages'] = self.get_md5_per_page_for_fork(
                 idx_ptrack[i]['path'], idx_ptrack[i]['old_size'])
 
-        self.backup_node(backup_dir, 'node', node, options=['-j100', '--stream'])
+        self.backup_node(backup_dir, 'node', node, options=['-j10', '--stream'])
 
         node.safe_psql('postgres', 'delete from t_heap where id%2 = 1')
         node.safe_psql('postgres', 'cluster t_heap using t_btree')
@@ -103,7 +103,7 @@ def test_ptrack_cluster_on_gist(self):
             idx_ptrack[i]['old_pages'] = self.get_md5_per_page_for_fork(
                 idx_ptrack[i]['path'], idx_ptrack[i]['old_size'])
 
-        self.backup_node(backup_dir, 'node', node, options=['-j100', '--stream'])
+        self.backup_node(backup_dir, 'node', node, options=['-j10', '--stream'])
 
         node.safe_psql('postgres', 'delete from t_heap where id%2 = 1')
         node.safe_psql('postgres', 'cluster t_heap using t_gist')
@@ -172,7 +172,7 @@ def test_ptrack_cluster_on_btree_replica(self):
             idx_ptrack[i]['old_pages'] = self.get_md5_per_page_for_fork(
                 idx_ptrack[i]['path'], idx_ptrack[i]['old_size'])
 
-        self.backup_node(backup_dir, 'replica', replica, options=['-j100', '--stream',
+        self.backup_node(backup_dir, 'replica', replica, options=['-j10', '--stream',
             '--master-host=localhost', '--master-db=postgres', '--master-port={0}'.format(master.port)])
 
         master.safe_psql('postgres', 'delete from t_heap where id%2 = 1')
@@ -242,7 +242,7 @@ def test_ptrack_cluster_on_gist_replica(self):
             idx_ptrack[i]['old_pages'] = self.get_md5_per_page_for_fork(
                 idx_ptrack[i]['path'], idx_ptrack[i]['old_size'])
 
-        self.backup_node(backup_dir, 'replica', replica, options=['-j100', '--stream',
+        self.backup_node(backup_dir, 'replica', replica, options=['-j10', '--stream',
             '--master-host=localhost', '--master-db=postgres', '--master-port={0}'.format(master.port)])
 
         master.safe_psql('postgres', 'delete from t_heap where id%2 = 1')

tests/ptrack_truncate.py

@@ -45,7 +45,7 @@ def test_ptrack_truncate(self):
                 idx_ptrack[i]['path'], idx_ptrack[i]['old_size'])
 
         # Make full backup to clean every ptrack
-        self.backup_node(backup_dir, 'node', node, options=['-j100', '--stream'])
+        self.backup_node(backup_dir, 'node', node, options=['-j10', '--stream'])
         for i in idx_ptrack:
             idx_ptrack[i]['ptrack'] = self.get_ptrack_bits_per_page_for_fork(
                 node, idx_ptrack[i]['path'], [idx_ptrack[i]['old_size']])
@@ -100,7 +100,7 @@ def test_ptrack_truncate_replica(self):
                 idx_ptrack[i]['path'], idx_ptrack[i]['old_size'])
 
         # Make full backup to clean every ptrack
-        self.backup_node(backup_dir, 'replica', replica, options=['-j100', '--stream'])
+        self.backup_node(backup_dir, 'replica', replica, options=['-j10', '--stream'])
         for i in idx_ptrack:
             idx_ptrack[i]['ptrack'] = self.get_ptrack_bits_per_page_for_fork(
                 replica, idx_ptrack[i]['path'], [idx_ptrack[i]['old_size']])

tests/ptrack_vacuum.py

@@ -45,7 +45,7 @@ def test_ptrack_vacuum(self):
                 idx_ptrack[i]['path'], idx_ptrack[i]['old_size'])
 
         # Make full backup to clean every ptrack
-        self.backup_node(backup_dir, 'node', node, options=['-j100', '--stream'])
+        self.backup_node(backup_dir, 'node', node, options=['-j10', '--stream'])
         for i in idx_ptrack:
             idx_ptrack[i]['ptrack'] = self.get_ptrack_bits_per_page_for_fork(
                 node, idx_ptrack[i]['path'], [idx_ptrack[i]['old_size']])

tests/ptrack_vacuum_bits_frozen.py

@@ -43,7 +43,7 @@ def test_ptrack_vacuum_bits_frozen(self):
             idx_ptrack[i]['old_pages'] = self.get_md5_per_page_for_fork(
                 idx_ptrack[i]['path'], idx_ptrack[i]['old_size'])
 
-        self.backup_node(backup_dir, 'node', node, options=['-j100', '--stream'])
+        self.backup_node(backup_dir, 'node', node, options=['-j10', '--stream'])
 
         node.safe_psql('postgres', 'vacuum freeze t_heap')
         node.safe_psql('postgres', 'checkpoint')
@@ -111,7 +111,7 @@ def test_ptrack_vacuum_bits_frozen_replica(self):
                 idx_ptrack[i]['path'], idx_ptrack[i]['old_size'])
 
         # Take PTRACK backup to clean every ptrack
-        self.backup_node(backup_dir, 'replica', replica, options=['-j100',
+        self.backup_node(backup_dir, 'replica', replica, options=['-j10',
             '--master-host=localhost', '--master-db=postgres', '--master-port={0}'.format(master.port)])
 
         master.safe_psql('postgres', 'vacuum freeze t_heap')

tests/ptrack_vacuum_full.py

@@ -44,7 +44,7 @@ def test_ptrack_vacuum_full(self):
             idx_ptrack[i]['old_pages'] = self.get_md5_per_page_for_fork(
                 idx_ptrack[i]['path'], idx_ptrack[i]['old_size'])
 
-        self.backup_node(backup_dir, 'node', node, options=['-j100', '--stream'])
+        self.backup_node(backup_dir, 'node', node, options=['-j10', '--stream'])
 
         node.safe_psql('postgres', 'delete from t_heap where id%2 = 1')
         node.safe_psql('postgres', 'vacuum full t_heap')

tests/ptrack_vacuum_truncate.py

@@ -44,7 +44,7 @@ def test_ptrack_vacuum_truncate(self):
             idx_ptrack[i]['old_pages'] = self.get_md5_per_page_for_fork(
                 idx_ptrack[i]['path'], idx_ptrack[i]['old_size'])
 
-        self.backup_node(backup_dir, 'node', node, options=['-j100', '--stream'])
+        self.backup_node(backup_dir, 'node', node, options=['-j10', '--stream'])
 
         node.safe_psql('postgres', 'delete from t_heap where id > 128;')
         node.safe_psql('postgres', 'vacuum t_heap')
@@ -116,7 +116,7 @@ def test_ptrack_vacuum_truncate_replica(self):
                 idx_ptrack[i]['path'], idx_ptrack[i]['old_size'])
 
         # Take PTRACK backup to clean every ptrack
-        self.backup_node(backup_dir, 'replica', replica, options=['-j100',
+        self.backup_node(backup_dir, 'replica', replica, options=['-j10',
             '--master-host=localhost', '--master-db=postgres', '--master-port={0}'.format(master.port)])
 
         master.safe_psql('postgres', 'delete from t_heap where id > 128;')