Commit f6b3945b authored by Ivan Tyagov's avatar Ivan Tyagov

In Default Wendelin we assume that all references (and tags in fluent-bit/fluentd

context) have this format.

sensor.product

Thus be consistent also here for Data Streams' reference.
parent 259eaa68
Pipeline #32136 failed with stage
in 0 seconds
...@@ -84,7 +84,7 @@ def init_input_line(input_line, operation_line): ...@@ -84,7 +84,7 @@ def init_input_line(input_line, operation_line):
if data_sink is None: if data_sink is None:
data_sink = portal.getDefaultModule(data_sink_type).newContent( data_sink = portal.getDefaultModule(data_sink_type).newContent(
portal_type = data_sink_type, portal_type = data_sink_type,
reference = "%s-%s" %(data_ingestion_reference, resource_reference)) reference = "%s.%s" %(data_ingestion_reference, resource_reference))
data_sink.validate() data_sink.validate()
data_sink_list.append(data_sink) data_sink_list.append(data_sink)
......
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