import json import numpy from cam_server.pipeline.data_processing import functions from logging import getLogger _logger = getLogger(__name__) def process(data, pulse_id, timestamp, parameters): ret = {} ret["test"] = 1 return ret