Changing cross-agent synchronization mechanism to socket-based with z…

[zomux]

Changing cross-agent synchronization mechanism to socket-based with zeromq; Changed agent meta class to lazy initialization to resolve cross-process sync problems

The developer interface will look like

from chorus.core import Chorus

from chorus.agents import  TaskCoordinatorAgent, ConversationalTaskAgent
from chorus.teams import Team
from chorus.collaboration import CentralizedCollaboration

from chorus.toolbox import WebRetrieverTool
from chorus.toolbox import DuckDuckGoWebSearchTool

from chorus.workspace import NoActivityStopper


if __name__ == '__main__':
    coordinator_agent = TaskCoordinatorAgent(
        instruction="""
        Do not do any task by yourself, always try to call other agents.
        If there is no relevant agent available, tell the user that you do not have a agent to answer the question.
        Make your answer comprehensive and detailed.
        """,
        reachable_agents={
            "FactResearchAgent": "An agent that can help user to find facts related to fitness and summarize them by search web and access pages.",
            "KnowledgeAgent": "An agent that can help user to answer general questions about fitness." 
        }
    ).name("FitnessAnsweringAgent")
    
    fact_research_agent = ConversationalTaskAgent(
        instruction="You can help user to find facts related to fitness and summarize them by search web and access pages.",
        tools=[
            DuckDuckGoWebSearchTool(),
            WebRetrieverTool()
        ]
    ).name("FactResearchAgent")
    
    knowledge_agent = ConversationalTaskAgent(
        instruction="Help user to answer general questions about fitness, nutrition, exercise and healthy lifestyle.",
    ).name("KnowledgeAgent")

    team = Team(
        name="HelloWorldTeam",
        agents=[coordinator_agent, fact_research_agent, knowledge_agent],
        collaboration=CentralizedCollaboration(
            coordinator=coordinator_agent.identifier()
        )
    )

    chorus = Chorus(
        teams=[team],
        stop_conditions=[NoActivityStopper()]
    )
    chorus.start()

    msg = chorus.send_and_wait(
        destination=team.identifier(),
        message="What are the best parks in New York City for running?"
    )
    print(msg.content)
    chorus.stop()

[zomux]

Start to merge PR 25 since all other features depend on it.

[ybdarrenwang]

I don't mind moving name functionality outside of init. But do we have any default naming mechanism for cases when traceability is desired but user didn't assign agent names, e.g. voting?

[ybdarrenwang]

Why this's not put in tests folder instead?

[ybdarrenwang]

Is this import needed?

[ybdarrenwang]

Not sure why we need two difference concept of name vs identifier.

[ybdarrenwang]

Can you explain what's this for?

[ybdarrenwang]

Doesn't seem needed

[ybdarrenwang]

I see we name-changed message_service to message_client everywhere. Any reason behind this?