← Back to branch summary

~credativ/openobject-addons/c2c-extra

« back to all changes in this revision

Viewing changes to etl/specs/prototype2/proto_new.py

  • Committer: ksa (Open ERP)
  • Date: 2010-07-06 05:10:58 UTC
  • Revision ID: ksa@tinyerp.co.in-20100706051058-x96e97ij1pvuu9ey
[IMP]:Remove print statement

Show diffs side-by-side

added added

removed removed

Lines of Context:
etl/specs/prototype2/proto_new.py
19
19
        return self.generator
20
20
 
21
21
    def channel_get(self, trans=None):
22
 
        self.data.setdefault(trans, [])        
 
22
        self.data.setdefault(trans, [])
23
23
        gen = self.generator_get(trans) or []
24
24
        while True:
25
25
            if self.data[trans]:
26
26
                yield self.data[trans].pop(0)
27
27
                continue
28
28
            elif self.data[trans] is None:
29
 
                raise StopIteration            
 
29
                raise StopIteration
30
30
            data, chan = gen.next()
31
31
            if data is None:
32
32
                raise StopIteration
65
65
        datas = []
66
66
        for channel,trans in self.input_get().items():
67
67
            for iterator in trans:
68
 
                for d in iterator:                    
 
68
                for d in iterator:
69
69
                    if not fp2:
70
70
                        fp2 = file(self.filename, 'wb+')
71
71
                        fieldnames = d.keys()
143
143
    def process(self):
144
144
        for channel,trans in self.input_get().items():
145
145
            for iterator in trans:
146
 
                for d in iterator:                    
 
146
                for d in iterator:
147
147
                    self.output.write('\tLog '+self.name+str(d)+'\n')
148
148
                    yield d, 'main'
149
149
 
162
162
            result.append(row[k])
163
163
        return tuple(result)
164
164
 
165
 
    def process(self):  
166
 
        self.row = {}      
167
 
        for channel,transition in self.input_get().items():            
 
165
    def process(self):
 
166
        self.row = {}
 
167
        for channel,transition in self.input_get().items():
168
168
            if channel not in self.row:
169
169
                self.row[channel] = {}
170
 
            other = None            
 
170
            other = None
171
171
            for key in self.row.keys():
172
172
                if key<>channel:
173
173
                    other = key
174
174
                    break
175
175
            for iterator in transition:
176
 
                for r in iterator: 
 
176
                for r in iterator:
177
177
                    key = self.key_get(r)
178
178
                    if other and (key in self.row[other]):
179
179
                        if self.row[other][key] == r:
180
 
                            yield r, 'same'                            
 
180
                            yield r, 'same'
181
181
                        else:
182
 
                            yield r, 'update' 
 
182
                            yield r, 'update'
183
183
                        del self.row[other][key]
184
184
                    else:
185
 
                        self.row[channel][key] = r         
 
185
                        self.row[channel][key] = r
186
186
        todo = ['add','remove']
187
 
        for k in self.row:     
188
 
            channel= todo.pop()                   
 
187
        for k in self.row:
 
188
            channel= todo.pop()
189
189
            for v in self.row[k].values():
190
 
                yield v,channel               
 
190
                yield v,channel
191
191
 
192
192
 
193
193
 
279
279
 
280
280
#class a(object):
281
281
#    def test(self, hello):
282
 
#        print hello
283
282
#b=a()
284
283
#
285
284
#import pickle