Commitcc4361c

committed

get_process_children is updated

1 parent230e562 commitcc4361cCopy full SHA for cc4361c

File tree

-3

lines changed

-3

lines changed

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -418,6 +418,7 @@ def get_pid(self):`
`418`	`418`	`returnos.getpid()`
`419`	`419`
`420`	`420`	`defget_process_children(self,pid):`
	`421`	`+asserttype(pid)==int# noqa: E721`
`421`	`422`	`returnpsutil.Process(pid).children()`
`422`	`423`
`423`	`424`	`# Database control`

Lines changed: 4 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -599,15 +599,16 @@ def get_pid(self):`
`599`	`599`	`returnint(self.exec_command("echo $$",encoding=get_default_encoding()))`
`600`	`600`
`601`	`601`	`defget_process_children(self,pid):`
`602`		`-command= ["ssh"]+self.ssh_args+ [self.ssh_dest,f"pgrep -P{pid}"]`
	`602`	`+asserttype(pid)==int# noqa: E721`
	`603`	`+command= ["ssh"]+self.ssh_args+ [self.ssh_dest,"pgrep","-P",str(pid)]`
`603`	`604`
`604`	`605`	`result=subprocess.run(command,stdout=subprocess.PIPE,stderr=subprocess.PIPE,text=True)`
`605`	`606`
`606`	`607`	`ifresult.returncode==0:`
`607`	`608`	`children=result.stdout.strip().splitlines()`
`608`	`609`	`return [PsUtilProcessProxy(self,int(child_pid.strip()))forchild_pidinchildren]`
`609`		`-else:`
`610`		`-raiseExecUtilException(f"Error in getting process children. Error:{result.stderr}")`
	`610`	`+`
	`611`	`+raiseExecUtilException(f"Error in getting process children. Error:{result.stderr}")`
`611`	`612`
`612`	`613`	`# Database control`
`613`	`614`	`defdb_connect(self,dbname,user,password=None,host="localhost",port=5432):`

Comments

(0)