diff --git a/karton/mwdb_reporter/mwdb_reporter.py b/karton/mwdb_reporter/mwdb_reporter.py index f6514df..a9142b5 100644 --- a/karton/mwdb_reporter/mwdb_reporter.py +++ b/karton/mwdb_reporter/mwdb_reporter.py @@ -521,6 +521,11 @@ def process_blob(self, task: Task) -> None: ) def process(self, task: Task) -> None: + if task.has_payload("properties"): + if task.get_payload("properties").get("volatile"): + self.log.info("Not reporting volatile task") + return + object_type = task.headers["type"] mwdb_object: Optional[MWDBObject]