diff --git a/src/components/archive_synchronizer.py b/src/components/archive_synchronizer.py index 0eb3577..92dd4fa 100644 --- a/src/components/archive_synchronizer.py +++ b/src/components/archive_synchronizer.py @@ -46,10 +46,11 @@ class ArchiveSynchronizer(Component): self._do_set_period({"period": float(self.config[self.name]["poll_time"])}) self.hold_time = round(float(self.config[self.name]["hold_time"]) * 1000) - self.gcs_client = storage.Client.from_service_account_json(self.config[self.name]["service_account_json"]) - self.gcs_client._http.mount("", HTTPAdapter(max_retries=Retry(total=0))) # this seems to be useless - self.gcs_client._http.adapters.move_to_end("", last=False) # this seems to be useless - self.bucket_id = self.config[self.name]["bucket_id"] + if self.name == "archive_synchronizer": + self.gcs_client = storage.Client.from_service_account_json(self.config[self.name]["service_account_json"]) + self.gcs_client._http.mount("", HTTPAdapter(max_retries=Retry(total=0))) # this seems to be useless + self.gcs_client._http.adapters.move_to_end("", last=False) # this seems to be useless + self.bucket_id = self.config[self.name]["bucket_id"] self.gcs_bucket = None @db.connection_context()