Commit a9ba8af3 authored by Ivan Tyagov's avatar Ivan Tyagov

Cleanup.

parent fb636ca0
...@@ -349,61 +349,14 @@ class Test(ERP5TypeTestCase): ...@@ -349,61 +349,14 @@ class Test(ERP5TypeTestCase):
Test ingestion using a POST Request containing a msgpack encoded message Test ingestion using a POST Request containing a msgpack encoded message
simulating input from fluentd. simulating input from fluentd.
""" """
from datetime import datetime, timedelta from datetime import datetime
import time import time
portal = self.portal portal = self.portal
now = datetime.now() now = datetime.now()
reference="test_sensor.test_product" reference="test_sensor.test_product"
title = reference
ingestion_policy = portal.portal_ingestion_policies['default'] ingestion_policy = portal.portal_ingestion_policies['default']
# create related data supply and etc.
use_category = portal.restrictedTraverse("portal_categories/use/big_data/ingestion/stream")
data_operation = portal.restrictedTraverse("data_operation_module/wendelin_ingest_data")
# create Data Product
#data_product = portal.data_product_module.newContent(
# portal_type = "Data Product",
# title = "Append to Data Stream",
# reference = reference.split('.')[1])
#data_product.setUseValue(use_category)
#data_product.setAggregatedPortalTypeList(["Data Stream", "Progress Indicator"])
#data_product.validate()
# create Data Supply
#data_supply_kw = {'title': title,
# 'reference': reference.split('.')[0],
# 'version': '001',
# 'effective_date': now,
# 'expiration_date': now + timedelta(days=365)}
#data_supply = portal.data_supply_module.newContent( \
# portal_type='Data Supply', **data_supply_kw)
#data_supply.validate()
# add ingestion line
#data_supply_line_kw = {'title': 'Ingest Data',
# 'reference': 'ingestion_operation',
# 'int_index': 1,
# 'quantity': 1.0}
#data_supply_line = data_supply.newContent(portal_type='Data Supply Line', **data_supply_line_kw)
#data_supply_line.setResourceValue(data_operation)
# add append to Data Stream line
#data_supply_line_kw = {'title': 'Data Stream',
# 'reference': 'out_stream',
# 'int_index': 2,
# 'quantity': 1.0}
#data_supply_line = data_supply.newContent(portal_type='Data Supply Line', \
# **data_supply_line_kw)
#data_supply_line.setResourceValue(data_product)
#data_supply_line.setUseValue(use_category)
#self.tic()
data_supply = portal.data_supply_module["default"] data_supply = portal.data_supply_module["default"]
data_list = [] data_list = []
......
...@@ -45,12 +45,7 @@ ...@@ -45,12 +45,7 @@
<item> <item>
<key> <string>text_content_warning_message</string> </key> <key> <string>text_content_warning_message</string> </key>
<value> <value>
<tuple> <tuple/>
<string>W:366, 4: Unused variable \'data_operation\' (unused-variable)</string>
<string>W:352, 4: Unused variable \'timedelta\' (unused-variable)</string>
<string>W:359, 4: Unused variable \'title\' (unused-variable)</string>
<string>W:364, 4: Unused variable \'use_category\' (unused-variable)</string>
</tuple>
</value> </value>
</item> </item>
<item> <item>
......
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