def upload_blob()

in backend/matching-engine/storage_helper.py [0:0]


def upload_blob(source_file_name: str, bucket_name: str, destination_blob_name: str):
    """Uploads a file to the bucket."""

    bucket_name, blob_name = extract_bucket_and_prefix_from_gcs_path(
        f"{bucket_name}/{destination_blob_name}/{Path(source_file_name).stem}"
    )

    storage_client = storage.Client()
    bucket = storage_client.bucket(bucket_name)
    blob = bucket.blob(blob_name)

    blob.upload_from_filename(source_file_name)

    destination_file_name = os.path.join("gs://", bucket_name, blob_name or "")

    return destination_file_name