self.logger.info("workflow function : {}".format(workflow_function))
return await workflow_function(op_id, op_params, content)
- async def dummy_clean_items(self, key, op_id, op_params, content):
+ async def dummy_clean_items(self, op_id, op_params, content):
self.logger.info(
- f"Dummy clean items. Key: {key}. Operation: {op_id}. Params: {op_params}. Content: {content}"
+ f"dummy_clean_items Enter. Operation {op_id}. Params: {op_params}"
)
+ self.logger.debug(f"Content: {content}")
return True, "OK"
async def clean_items_workflow(self, key, op_id, op_params, content):