@@ -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