HCE Project Python language Distributed Tasks Manager Application, Distributed Crawler Application and client API bindings.  2.0.0-chaika
Hierarchical Cluster Engine Python language binding
ftests.ftest_join Namespace Reference

Functions

def execute (cmd)
 
def makeInputFileList (dataDir, delimiter=None)
 
def testExecute (cmd, files)
 

Variables

string testDataDir = './join-convertor-data'
 
string testOutputFile = '/tmp/join_output_file.json'
 
string testDelimiter = ';'
 
string delimiterTemplate = "--delimiter='%s'"
 
string firstCmdTemplate = "cd ~/hce-node-bundle/api/python/bin && ./join.py --files='%s' --output_file='%s'"
 
string secondCmdTemplate = "cd ~/hce-node-bundle/api/python/bin && ./join.py --files='%s'"
 
def files = makeInputFileList(testDataDir, testDelimiter)
 
tuple cmd = (firstCmdTemplate % (files, testOutputFile)) + ' ' + (delimiterTemplate % testDelimiter)
 

Detailed Description

HCE project, Python bindings, DC dependencies
The join tools research tests.

@package: drce
@author Alexander Vybornyh <alexander.hce.cluster@gmail.com>
@link: http://hierarchical-cluster-engine.com/
@copyright: Copyright &copy; 2013-2016 IOIX Ukraine
@license: http://hierarchical-cluster-engine.com/license/
@since: 0.1

Function Documentation

◆ execute()

def ftests.ftest_join.execute (   cmd)

Definition at line 34 of file ftest_join.py.

34 def execute(cmd):
35  process = Popen(cmd, stdout=PIPE, stdin=PIPE, stderr=PIPE, shell=True, close_fds=True)
36  output, err = process.communicate()
37  exitCode = process.wait()
38  return output, err, exitCode
39 
40 
def execute(cmd)
Definition: ftest_join.py:34
Here is the caller graph for this function:

◆ makeInputFileList()

def ftests.ftest_join.makeInputFileList (   dataDir,
  delimiter = None 
)

Definition at line 41 of file ftest_join.py.

41 def makeInputFileList(dataDir, delimiter=None):
42  # variable for result
43  ret = ''
44 
45  if os.path.isdir(dataDir):
46  filesList = [os.path.abspath(os.path.join(dataDir, f)) for f in os.listdir(dataDir) if os.path.isfile(os.path.join(dataDir, f))]
47 
48  if delimiter is None:
49  delimiter = ' '
50 
51  ret = delimiter.join(filesList)
52 
53  return ret
54 
55 
def makeInputFileList(dataDir, delimiter=None)
Definition: ftest_join.py:41

◆ testExecute()

def ftests.ftest_join.testExecute (   cmd,
  files 
)

Definition at line 56 of file ftest_join.py.

56 def testExecute(cmd, files):
57  print ("cmd: " + str(cmd))
58 
59  output, err, exitCode = execute(cmd)
60  print ("exitCode: " + str(exitCode))
61  print ("error: " + str(err))
62  print ("output: " + str(output))
63 
64 
def execute(cmd)
Definition: ftest_join.py:34
def testExecute(cmd, files)
Definition: ftest_join.py:56
Here is the call graph for this function:

Variable Documentation

◆ cmd

string ftests.ftest_join.cmd = (firstCmdTemplate % (files, testOutputFile)) + ' ' + (delimiterTemplate % testDelimiter)

Definition at line 69 of file ftest_join.py.

◆ delimiterTemplate

string ftests.ftest_join.delimiterTemplate = "--delimiter='%s'"

Definition at line 29 of file ftest_join.py.

◆ files

def ftests.ftest_join.files = makeInputFileList(testDataDir, testDelimiter)

Definition at line 66 of file ftest_join.py.

◆ firstCmdTemplate

string ftests.ftest_join.firstCmdTemplate = "cd ~/hce-node-bundle/api/python/bin && ./join.py --files='%s' --output_file='%s'"

Definition at line 30 of file ftest_join.py.

◆ secondCmdTemplate

string ftests.ftest_join.secondCmdTemplate = "cd ~/hce-node-bundle/api/python/bin && ./join.py --files='%s'"

Definition at line 31 of file ftest_join.py.

◆ testDataDir

string ftests.ftest_join.testDataDir = './join-convertor-data'

Definition at line 25 of file ftest_join.py.

◆ testDelimiter

string ftests.ftest_join.testDelimiter = ';'

Definition at line 27 of file ftest_join.py.

◆ testOutputFile

string ftests.ftest_join.testOutputFile = '/tmp/join_output_file.json'

Definition at line 26 of file ftest_join.py.