How to connect to weaviate embedded, if already running reconnect otherwise instantiate a new instance

connect_weaviate_embedded

def get_weaviate():
   
    try:
        # Try to connect to an existing Weaviate instance
        client = weaviate.connect_to_local(port=8079, grpc_port=50060)
        if client.is_ready():
            print("Connected to an already running Weaviate instance.")
            return client
        # else:
        #     print("Weaviate instance not ready.")
    except WeaviateConnectionError as e:
        print("No Weaviate instance is currently running; attempting to define a new embedded instance.")

    # Start Weaviate Embedded if no instance is running
        
        embedded_path = "./weaviate-data"  # Path for embedded data
        client = weaviate.WeaviateClient(
            additional_headers={
               "X-Cohere-Api-Key": <!!!!! ADD YOU API KEY HERE !!!!!!>
            },
            embedded_options=EmbeddedOptions(
            version="latest",
            additional_env_vars={
                "ENABLE_MODULES": "text2vec-openai,text2vec-cohere",
                "PERSISTENCE_DATA_PATH":embedded_path,
                "LOG_LEVEL":"error"
                
            },             
            
        ))
        print("Weaviate Embedded started.")
        if not client.is_connected():
            client.connect()
        return client
    except WeaviateBaseError as e:
        print(e)

# Connect to Weaviate
client = get_weaviate()