Searched refs:gcs_uri (Results 1 – 2 of 2) sorted by relevance
111 def send_test_job_offloaded_message(self, gcs_uri): argument181 def _create_test_job_offloaded_message(self, gcs_uri): argument195 msg_attributes[LEGACY_ATTR_GCS_URI] = gcs_uri200 def send_test_job_offloaded_message(self, gcs_uri): argument208 logging.info('Notification on gcs_uri %s', gcs_uri)209 message = self._create_test_job_offloaded_message(gcs_uri)
837 gcs_uri = os.path.join(gs_path,840 gcs_uri):