Commit 85d24341 authored by Roque's avatar Roque

erp5_wendelin_data_lake_ingestion: rename data supply

parent d2600881
...@@ -86,7 +86,7 @@ ...@@ -86,7 +86,7 @@
</item> </item>
<item> <item>
<key> <string>default_reference</string> </key> <key> <string>default_reference</string> </key>
<value> <string>embulk</string> </value> <value> <string>default_ebulk</string> </value>
</item> </item>
<item> <item>
<key> <string>description</string> </key> <key> <string>description</string> </key>
...@@ -132,7 +132,7 @@ ...@@ -132,7 +132,7 @@
</item> </item>
<item> <item>
<key> <string>id</string> </key> <key> <string>id</string> </key>
<value> <string>embulk</string> </value> <value> <string>default_ebulk</string> </value>
</item> </item>
<item> <item>
<key> <string>language</string> </key> <key> <string>language</string> </key>
...@@ -146,7 +146,7 @@ ...@@ -146,7 +146,7 @@
</item> </item>
<item> <item>
<key> <string>title</string> </key> <key> <string>title</string> </key>
<value> <string>Embulk</string> </value> <value> <string>Ebulk</string> </value>
</item> </item>
<item> <item>
<key> <string>version</string> </key> <key> <string>version</string> </key>
...@@ -329,7 +329,7 @@ ...@@ -329,7 +329,7 @@
</item> </item>
<item> <item>
<key> <string>serial</string> </key> <key> <string>serial</string> </key>
<value> <string>960.15698.49376.7287</string> </value> <value> <string>985.36429.29664.46233</string> </value>
</item> </item>
<item> <item>
<key> <string>state</string> </key> <key> <string>state</string> </key>
...@@ -347,7 +347,7 @@ ...@@ -347,7 +347,7 @@
</tuple> </tuple>
<state> <state>
<tuple> <tuple>
<float>1498225133.32</float> <float>1595958580.55</float>
<string>UTC</string> <string>UTC</string>
</tuple> </tuple>
</state> </state>
......
...@@ -214,7 +214,7 @@ ...@@ -214,7 +214,7 @@
</item> </item>
<item> <item>
<key> <string>serial</string> </key> <key> <string>serial</string> </key>
<value> <string>959.7816.8415.26299</string> </value> <value> <string>985.17805.27243.30754</string> </value>
</item> </item>
<item> <item>
<key> <string>state</string> </key> <key> <string>state</string> </key>
...@@ -232,7 +232,7 @@ ...@@ -232,7 +232,7 @@
</tuple> </tuple>
<state> <state>
<tuple> <tuple>
<float>1498225125.16</float> <float>1595958567.14</float>
<string>UTC</string> <string>UTC</string>
</tuple> </tuple>
</state> </state>
......
...@@ -220,7 +220,7 @@ ...@@ -220,7 +220,7 @@
</item> </item>
<item> <item>
<key> <string>serial</string> </key> <key> <string>serial</string> </key>
<value> <string>959.7816.8415.26299</string> </value> <value> <string>985.17805.27243.30754</string> </value>
</item> </item>
<item> <item>
<key> <string>state</string> </key> <key> <string>state</string> </key>
...@@ -238,7 +238,7 @@ ...@@ -238,7 +238,7 @@
</tuple> </tuple>
<state> <state>
<tuple> <tuple>
<float>1498225125.15</float> <float>1595958567.15</float>
<string>UTC</string> <string>UTC</string>
</tuple> </tuple>
</state> </state>
......
...@@ -33,7 +33,7 @@ if data_ingestion is not None: ...@@ -33,7 +33,7 @@ if data_ingestion is not None:
specialise_value_list = [x.getObject() for x in portal_catalog.searchResults( specialise_value_list = [x.getObject() for x in portal_catalog.searchResults(
portal_type = 'Data Supply', portal_type = 'Data Supply',
reference = 'embulk', reference = 'default_ebulk',
validation_state = 'validated')] validation_state = 'validated')]
# create a new data ingestion # create a new data ingestion
......
...@@ -216,11 +216,11 @@ class TestDataIngestion(SecurityTestCase): ...@@ -216,11 +216,11 @@ class TestDataIngestion(SecurityTestCase):
self.assertNotEqual(None, self.assertNotEqual(None,
getattr(self.portal.portal_ingestion_policies, "default_ebulk", None)) getattr(self.portal.portal_ingestion_policies, "default_ebulk", None))
self.assertNotEqual(None, self.assertNotEqual(None,
getattr(self.portal.data_supply_module, "embulk", None)) getattr(self.portal.data_supply_module, "default_ebulk", None))
def test_04_DefaultModelSecurityModel(self): def test_04_DatasetAndDatastreamsConsistency(self):
""" """
Test default security model : 'All can download, only contributors can upload.' Test that data set state transition also changes its data streams states
""" """
data_set, data_stream_list = self.stepIngest(self.CSV, ",", randomize_ingestion_reference=True) data_set, data_stream_list = self.stepIngest(self.CSV, ",", randomize_ingestion_reference=True)
self.tic() self.tic()
......
...@@ -3,8 +3,8 @@ data_operation_module/transform_fif ...@@ -3,8 +3,8 @@ data_operation_module/transform_fif
data_product_module/fif_array data_product_module/fif_array
data_product_module/fif_data data_product_module/fif_data
data_product_module/fif_descriptor data_product_module/fif_descriptor
data_supply_module/embulk data_supply_module/default_ebulk
data_supply_module/embulk/** data_supply_module/default_ebulk/**
portal_ingestion_policies/wendelin_embulk portal_ingestion_policies/wendelin_embulk
portal_ingestion_policies/default_ebulk portal_ingestion_policies/default_ebulk
portal_categories/function/** portal_categories/function/**
......
...@@ -3,8 +3,8 @@ data_operation_module/transform_fif ...@@ -3,8 +3,8 @@ data_operation_module/transform_fif
data_product_module/fif_array data_product_module/fif_array
data_product_module/fif_data data_product_module/fif_data
data_product_module/fif_descriptor data_product_module/fif_descriptor
data_supply_module/embulk data_supply_module/default_ebulk
data_supply_module/embulk/** data_supply_module/default_ebulk/**
portal_ingestion_policies/wendelin_embulk portal_ingestion_policies/wendelin_embulk
portal_ingestion_policies/default_ebulk portal_ingestion_policies/default_ebulk
portal_categories/use/** portal_categories/use/**
\ No newline at end of file
...@@ -3,8 +3,8 @@ data_operation_module/transform_fif ...@@ -3,8 +3,8 @@ data_operation_module/transform_fif
data_product_module/fif_array data_product_module/fif_array
data_product_module/fif_data data_product_module/fif_data
data_product_module/fif_descriptor data_product_module/fif_descriptor
data_supply_module/embulk data_supply_module/default_ebulk
data_supply_module/embulk/** data_supply_module/default_ebulk/**
portal_alarms/wendelin_check_datastream_consistency portal_alarms/wendelin_check_datastream_consistency
portal_alarms/wendelin_check_datastream_consistency/** portal_alarms/wendelin_check_datastream_consistency/**
portal_alarms/wendelin_data_lake_handle_analysis portal_alarms/wendelin_data_lake_handle_analysis
......
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