Untitled

def run_pipeline(enabled_vm_details):
    # Your Apache Beam pipeline code here, using the enabled_vm_details dictionary as needed

    # Example usage: print the dictionary
    print(enabled_vm_details)

# Call the get_vm_details function and pass in the returned dictionary to run_pipeline
enabled_vm_details = get_vm_details()
run_pipeline(enabled_vm_details)