← Back to branch summary

~openerp-commiter/openobject-addons/extra-6.0

« back to all changes in this revision

Viewing changes to etl/specs/prototype/diff_job1.py

  • Committer: Fabien Pinckaers
  • Date: 2009-01-12 07:30:23 UTC
  • Revision ID: fp@tinyerp.com-20090112073023-t6pon9a1d16bycby
Adding_specs_etl

Show diffs side-by-side

added added

removed removed

Lines of Context:
etl/specs/prototype/diff_job1.py
 
1
#! /usr/bin/python
 
2
 
 
3
import etl
 
4
 
 
5
in1 = etl.operator.etl_csv_input('data/partner.csv', is_start=True)
 
6
in2 = etl.operator.etl_csv_input('data/partner2.csv', is_start=True)
 
7
diff1 = etl.operator.etl_operator_diff(['id'])
 
8
 
 
9
log_1 = etl.operator.etl_operator_log_bloc(name="Original Data")
 
10
log_2 = etl.operator.etl_operator_log_bloc(name="Modified Data")
 
11
 
 
12
log1 = etl.operator.etl_operator_log(name="Log Same")
 
13
log2 = etl.operator.etl_operator_log(name="Log Add")
 
14
log3 = etl.operator.etl_operator_log(name="Log Remove")
 
15
log4 = etl.operator.etl_operator_log(name="Log Update")
 
16
 
 
17
 
 
18
csv1 = etl.operator.etl_csv_output('intermediate/add.csv')
 
19
 
 
20
etl.transition(in1, log_1)
 
21
etl.transition(in2, log_2)
 
22
 
 
23
etl.transition(in1, diff1, 'original')
 
24
etl.transition(in2, diff1, 'modified')
 
25
 
 
26
etl.transition(diff1, log1, channel_source="same")
 
27
etl.transition(diff1, log3, channel_source="remove")
 
28
etl.transition(diff1, log2, channel_source="add")
 
29
etl.transition(diff1, csv1, channel_source="add")
 
30
etl.transition(diff1, log4, channel_source="update")
 
31
 
 
32
job = etl.job([in1,in2,diff1])
 
33
job.run()
 
34