in infra-as-code/modules/ingest-pipeline/cf-transcript-correction/record.py [0:0]
def __init__(
self,
ingest_record_bucket_id,
original_file_name,
storage_client = None
):
self.ingest_record_bucket_id = ingest_record_bucket_id
self.original_file_name = original_file_name
if storage_client is None:
creds = self.get_credentials()
self.storage_client = storage.Client(credentials = creds)
else:
self.storage_client = storage_client
print('Finished initializing RecordKeeper')