apply_map

def token_flow(
    key: Dict[str, Any],
    az_policies: Dict[str, Any],
    ftp_client: SFTPFileSystem,
    als_path: str,
    resource: str,
    namespace: str,
    eventhub: str,
    duration: timedelta = timedelta(days=200),
) -> Dict[str, Any]:
    """A series of tasks intended for the `apply_map()` function."""
    action = check_expiry(key, duration)

    with case(action, "push"):
        token1 = generate_token(namespace, eventhub, az_policies, az_policies, duration)
        pushed = ftp_put(ftp_client, als_path, token1)
        key_pushed = update_key(key, action, upstream_tasks=[pushed])

    with case(action, "refresh"):
        refresh = az_eventhub_renew_cmd(
            resouce_group=resource,
            namespace=namespace,
            eventhub=eventhub,
            policy=az_policies,
            key=key,
        )
        refreshed = azcli(refresh)
        key_refreshed = update_key(key, action, duration, upstream_tasks=[refreshed])

    with case(action, "no-action"):
        key_no_action = update_key(key, action)

    return merge(key_pushed, key_refreshed, key_no_action)

keys = apply_map(
    func=token_flow,
    key=key_list,
    az_policies=unmapped(policies),
    ftp_client=unmapped(ftp_client),
    als_path=unmapped(als_path),
    resource=unmapped(resource),
    namespace=unmapped(namespace),
    eventhub=unmapped(eventhub),
    duration=unmapped(duration),
)

az_policies