Commit 085b15fa authored by Roque Porchetto's avatar Roque Porchetto

New supply for all ingestions: embulk.

parent cced6d72
......@@ -86,7 +86,7 @@
</item>
<item>
<key> <string>default_reference</string> </key>
<value> <string>telecom</string> </value>
<value> <string>embulk</string> </value>
</item>
<item>
<key> <string>description</string> </key>
......@@ -132,7 +132,7 @@
</item>
<item>
<key> <string>id</string> </key>
<value> <string>telecom</string> </value>
<value> <string>embulk</string> </value>
</item>
<item>
<key> <string>language</string> </key>
......@@ -146,7 +146,7 @@
</item>
<item>
<key> <string>title</string> </key>
<value> <string>Telecom</string> </value>
<value> <string>Embulk</string> </value>
</item>
<item>
<key> <string>version</string> </key>
......@@ -323,7 +323,7 @@
</item>
<item>
<key> <string>serial</string> </key>
<value> <string>958.21530.59410.64887</string> </value>
<value> <string>960.15698.49376.7287</string> </value>
</item>
<item>
<key> <string>state</string> </key>
......@@ -341,7 +341,7 @@
</tuple>
<state>
<tuple>
<float>1492069452.09</float>
<float>1498225133.32</float>
<string>UTC</string>
</tuple>
</state>
......
......@@ -212,7 +212,7 @@
</item>
<item>
<key> <string>serial</string> </key>
<value> <string>958.2619.38547.19438</string> </value>
<value> <string>959.7816.8415.26299</string> </value>
</item>
<item>
<key> <string>state</string> </key>
......@@ -230,7 +230,7 @@
</tuple>
<state>
<tuple>
<float>1492069598.21</float>
<float>1498225125.16</float>
<string>UTC</string>
</tuple>
</state>
......
......@@ -218,7 +218,7 @@
</item>
<item>
<key> <string>serial</string> </key>
<value> <string>958.2890.30700.54220</string> </value>
<value> <string>959.7816.8415.26299</string> </value>
</item>
<item>
<key> <string>state</string> </key>
......@@ -236,7 +236,7 @@
</tuple>
<state>
<tuple>
<float>1490797134.37</float>
<float>1498225125.15</float>
<string>UTC</string>
</tuple>
</state>
......
......@@ -37,16 +37,9 @@ if data_ingestion is None:
if data_ingestion is None:
specialise_value_list = [x.getObject() for x in portal_catalog.searchResults(
portal_type = 'Data Supply',
reference = specialise_reference,
reference = 'embulk',
validation_state = 'validated')]
# if we do not find a validated data supply, we look for a default data supply
if not specialise_value_list:
specialise_value_list = [x.getObject() for x in portal_catalog.searchResults(
portal_type = 'Data Supply',
reference = 'default',
validation_state = 'validated')]
log("Data Suppliers list: " + str(specialise_value_list))
# create a new data ingestion
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment