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()