def collect_data()

in src/dma/collector/workflows/collection_extractor/base.py [0:0]


    def collect_data(self, execution_id: str) -> None:
        sync_engine = get_engine(self.src_info, self.database)
        with Session(sync_engine) as db_session:
            collection_manager = next(
                provide_collection_query_manager(
                    db_session=db_session, execution_id=execution_id, manual_id=self.collection_identifier
                )
            )
            self.extract_collection(collection_manager)
            self.extract_extended_collection(collection_manager)
            self.process_collection()
            self.db_version = collection_manager.get_db_version()
        sync_engine.dispose()