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)