Commitb4e17e1

committed

[create_archive_push] archive_push_command in testgres_pg_probackup added

1 parent70d2f27 commitb4e17e1Copy full SHA for b4e17e1

File tree

+23

-0

lines changed

+23

-0

lines changed

Lines changed: 23 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -748,5 +748,28 @@ def load_backup_class(fs_type):`
`748`	`748`
`749`	`749`	`returngetattr(module,class_name)`
`750`	`750`
	`751`	`+defarchive_push(self,instance,node,wal_file_name,wal_file_path=None,options=None,expect_error=False):`
	`752`	`+ifoptionsisNone:`
	`753`	`+options= []`
	`754`	`+cmd= [`
	`755`	`+'archive-push',`
	`756`	`+'--instance={0}'.format(instance),`
	`757`	`+'--wal-file-name={0}'.format(wal_file_name),`
	`758`	`+ ]`
	`759`	`+ifwal_file_pathisNone:`
	`760`	`+cmd=cmd+ ['--wal-file-path={0}'.format(os.path.join(node.data_dir,'pg_wal'))]`
	`761`	`+returnself.run(cmd+options,expect_error=expect_error)`
	`762`	`+`
	`763`	`+`
	`764`	`+# Local or S3 backup`
	`765`	`+fs_backup_class=FSTestBackupDir`
	`766`	`+ifos.environ.get('PG_PROBACKUP_S3_TEST',os.environ.get('PROBACKUP_S3_TYPE_FULL_TEST')):`
	`767`	`+root=os.path.realpath(os.path.join(os.path.dirname(__file__),'../..'))`
	`768`	`+ifrootnotinsys.path:`
	`769`	`+sys.path.append(root)`
	`770`	`+frompg_probackup2.storage.s3_backupimportS3TestBackupDir`
	`771`	`+`
	`772`	`+fs_backup_class=S3TestBackupDir`
	`773`	`+`
`751`	`774`	`defbuild_backup_dir(self,backup='backup'):`
`752`	`775`	`returnfs_backup_class(rel_path=self.rel_path,backup=backup)`

Comments

(0)