##// END OF EJS Templates
fix multiSchain
jespinoza -
r895:d092fa5fcc1d
parent child
Show More
@@ -43,7 +43,10 def multiSchain(child, nProcess=cpu_count(), startDate=None, endDate=None):
43 dt = (dt1 + datetime.timedelta(day)).strftime('%Y/%m/%d')
43 dt = (dt1 + datetime.timedelta(day)).strftime('%Y/%m/%d')
44 firstProcess = Process(target=child, args=(cursor, skip, q, dt))
44 firstProcess = Process(target=child, args=(cursor, skip, q, dt))
45 firstProcess.start()
45 firstProcess.start()
46 print 'a'
46 nFiles = q.get()
47 nFiles = q.get()
48
49 print nFiles
47 firstProcess.terminate()
50 firstProcess.terminate()
48 skip = int(math.ceil(nFiles/nProcess))
51 skip = int(math.ceil(nFiles/nProcess))
49 try:
52 try:
@@ -826,6 +829,7 class ReadUnitConf(ProcUnitConf):
826 opObj.addParameter(name='endDate' , value=self.endDate, format='date')
829 opObj.addParameter(name='endDate' , value=self.endDate, format='date')
827 opObj.addParameter(name='startTime' , value=self.startTime, format='time')
830 opObj.addParameter(name='startTime' , value=self.startTime, format='time')
828 opObj.addParameter(name='endTime' , value=self.endTime, format='time')
831 opObj.addParameter(name='endTime' , value=self.endTime, format='time')
832 opObj.addParameter(name='queue' , value=self.queue, format='obj')
829
833
830 for key, value in kwargs.items():
834 for key, value in kwargs.items():
831 opObj.addParameter(name=key, value=value, format=type(value).__name__)
835 opObj.addParameter(name=key, value=value, format=type(value).__name__)
General Comments 0
You need to be logged in to leave comments. Login now