Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions gpMgmt/bin/gppylib/logfilter.py
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ def FilterLogEntries(iterable,
filters=[],
ibegin=0,
jend=None):
"""
r"""
Generator to consume the lines of a GPDB log file from iterable,
yield the lines which satisfy the given criteria, and skip the rest.
Expand Down Expand Up @@ -668,7 +668,7 @@ def MatchInFirstLine(iterable, regex):


def NoMatchInFirstLine(iterable, regex):
"""
r"""
Generator to filter a stream of groups. Skips those groups whose
first line contains a match for the given regex; yields all other
groups.
Expand Down
4 changes: 2 additions & 2 deletions gpMgmt/bin/gppylib/mainUtils.py
Original file line number Diff line number Diff line change
Expand Up @@ -488,7 +488,7 @@ def parseStatusLine(line, isStart = False, isStop = False):


def check_fts(fts):
fts_check_cmd= "ps -ef | awk '{print \$2, \$8}' | grep gpfts | grep -v grep"
fts_check_cmd= r"ps -ef | awk '{print \$2, \$8}' | grep gpfts | grep -v grep"
process_cmd = "gpssh -h %s -e \"%s\" | wc -l" % (fts, fts_check_cmd)
fts_process_res=int(subprocess.check_output(process_cmd, shell=True).decode().strip())
return fts_process_res == 2
Expand All @@ -500,7 +500,7 @@ def check_etcd(etcd):
if etcd_process_res == 2:
return True
# for demo cluster
etcd_check_cmd = "ps -ef | awk '{print \$2, \$8}' | grep etcd | grep -v grep"
etcd_check_cmd = r"ps -ef | awk '{print \$2, \$8}' | grep etcd | grep -v grep"
process_cmd = "gpssh -h %s -e \"%s\"| wc -l" % (etcd, etcd_check_cmd)
etcd_process_res = int(subprocess.check_output(process_cmd, shell=True).decode().strip())
return etcd_process_res == 2
Expand Down
Loading