def get_pipeline_id_for_migration(token: str) -> str:
    """Get pipeline id from single config api
    Returns:
        str: pipelineId
    """

    url = f"{XDR_HOST_URL}/beta/xdr/oat/dataPipeline"
    headers = get_header(
        {
            "Authorization": f"Bearer {token}",
            "Content-Type": "application/json",
        }
    )
    logger.info(f"Get oat pipeline id for migration: {url}.")
    response = requests.get(url, headers=headers)
    logger.info(f"Get oat pipeline id for migration, response: {response.text}, ")

    response.raise_for_status()
    response_data = response.json()
    return response_data["pipelineId"]
Get pipeline id from single config api
    Returns:
        str: pipelineId
    
Solutions/Trend Micro Vision One/Data Connectors/AzureFunctionTrendMicroXDR/shared_code/services/oat_service.py