Commit 1c930c97 authored by Klaus Wölfel's avatar Klaus Wölfel

ingest: re-add **kw

parent 70aa6521
...@@ -53,7 +53,7 @@ class IngestionPolicy(Folder): ...@@ -53,7 +53,7 @@ class IngestionPolicy(Folder):
return self.portal_ingestion_policies.unpack(data) return self.portal_ingestion_policies.unpack(data)
security.declarePublic('ingest') security.declarePublic('ingest')
def ingest(self, REQUEST): def ingest(self, REQUEST, **kw):
""" """
Ingest chunk of raw data either from a Sensor or any of DAUs. Ingest chunk of raw data either from a Sensor or any of DAUs.
""" """
...@@ -83,7 +83,7 @@ class IngestionPolicy(Folder): ...@@ -83,7 +83,7 @@ class IngestionPolicy(Folder):
# XXX Compatibility with old ingestion. Must be dropped before merging # XXX Compatibility with old ingestion. Must be dropped before merging
# with wendelin master # with wendelin master
if tag_parsing_script_id == "ERP5Site_handleDefaultFluentdIngestion": if tag_parsing_script_id == "ERP5Site_handleDefaultFluentdIngestion":
return tag_parsing_script() return tag_parsing_script(**kw)
reference = self.REQUEST.get('reference') reference = self.REQUEST.get('reference')
data_chunk = self.REQUEST.get('data_chunk') data_chunk = self.REQUEST.get('data_chunk')
......
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