| @@ -43,7 +43,10 def multiSchain(child, nProcess=cpu_count(), startDate=None, endDate=None): | |||
|
|
43 | 43 | dt = (dt1 + datetime.timedelta(day)).strftime('%Y/%m/%d') |
|
|
44 | 44 | firstProcess = Process(target=child, args=(cursor, skip, q, dt)) |
|
|
45 | 45 | firstProcess.start() |
|
|
46 | print 'a' | |
|
|
46 | 47 | nFiles = q.get() |
|
|
48 | ||
|
|
49 | print nFiles | |
|
|
47 | 50 | firstProcess.terminate() |
|
|
48 | 51 | skip = int(math.ceil(nFiles/nProcess)) |
|
|
49 | 52 | try: |
| @@ -826,6 +829,7 class ReadUnitConf(ProcUnitConf): | |||
|
|
826 | 829 | opObj.addParameter(name='endDate' , value=self.endDate, format='date') |
|
|
827 | 830 | opObj.addParameter(name='startTime' , value=self.startTime, format='time') |
|
|
828 | 831 | opObj.addParameter(name='endTime' , value=self.endTime, format='time') |
|
|
832 | opObj.addParameter(name='queue' , value=self.queue, format='obj') | |
|
|
829 | 833 | |
|
|
830 | 834 | for key, value in kwargs.items(): |
|
|
831 | 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