Untitled

def sanitize_key(key: str) -> str:
    """
    Airflow task_id ve name için geçerli hale getirir.
    Türkçe karakterleri ASCII'ye çevirir ve boşlukları/özel karakterleri alt çizgiye dönüştürür.
    """
    # Türkçe karakterleri ASCII'ye dönüştür (örnek: 'İşYeri' -> 'IsYeri')
    normalized = unicodedata.normalize('NFKD', key).encode('ascii', 'ignore').decode('ascii')
    # Geçersiz karakterleri alt çizgi yap
    safe_key = re.sub(r'[^a-zA-Z0-9_.-]', '_', normalized)
    return safe_key

    task_id = f"pivot_{sanitize_key(product_group.lower())}"

    name=f"pivot-{sanitize_key(product_group.lower())}-{{{{ ts_nodash }}}}",