def UploadFile(source, stage_bucket, messages, service, function_ref): if stage_bucket: return _UploadFileToGcs(source, function_ref, stage_bucket) return _UploadFileToGeneratedUrl(source, messages, service, function_ref)