add project in archive gcs prefix

Author: maxshine

src/customizable_continuous_integration/automations/bigquery_archiver/entity/dataset.py

@@ -6,6 +6,7 @@
   Date         Author		   Comments
 ------------------------------------------------------------------------------
   23/02/2025   Ryan, Gao       Initial creation
+  03/04/2025   Ryan, Gao       Set project in dataset gcs_prefix
 """
 
 import datetime
@@ -53,7 +54,7 @@ def entity_type(self) -> str:
 
     @property
     def archive_prefix(self):
-        return f"{self.gcs_prefix}/dataset={self.identity}/archive_ts={self.archived_datetime_str}"
+        return f"{self.gcs_prefix}/project={self.project_id}/dataset={self.identity}/archive_ts={self.archived_datetime_str}"
 
     @property
     def metadata_serialized_path(self):

src/customizable_continuous_integration/automations/bigquery_archiver/executor/restore.py

@@ -81,7 +81,7 @@ def execute(self) -> BigqueryArchivedDatasetEntity:
         concurrency = self.restore_config.get("concurrency", 1)
         continue_on_failure = self.restore_config.get("continue_on_failure", False)
 
-        self.logger.info(f"Restoring dataset itself {self.bigquery_archived_dataset_entity.fully_qualified_identity}")
+        self.logger.info(f"Restoring dataset {self.bigquery_archived_dataset_entity.fully_qualified_identity} itself")
         self.bigquery_archived_dataset_entity.restore_self(self.bigquery_client, self.restore_config)
         self.logger.info(f"Restoring entities in the dataset {self.bigquery_archived_dataset_entity.fully_qualified_identity}")
         with ThreadPoolExecutor(max_workers=concurrency) as executor: