diff --git a/modules/automation/automation.py b/modules/automation/automation.py index e447504..5eda7aa 100644 --- a/modules/automation/automation.py +++ b/modules/automation/automation.py @@ -186,13 +186,9 @@ class AutomationDocument(ModelSQL, ModelView, Workflow): def run_pipeline(cls, docs): for doc in docs: try: - metadata = cls.metadata_json - - if isinstance(metadata, str): - metadata = json.loads(metadata) - - if not isinstance(metadata, dict): - logger.info("NOT A JSON STRUCTURE:%s",metadata) + logger.info("DATA_TYPE:%s",type(cls.metadata_json)) + metadata = json.loads(cls.metadata_json) + logger.info("JSON STRUCTURE:%s",metadata) WeightReport = Pool().get('weight.report') WeightReport.create_from_json(metadata)