fix refactor, circular dependency

samples/apps/cap/py/autogencap/zmq_actor_connector.py

@@ -1,6 +1,3 @@
-# Agent_Sender takes a zmq context, Topic and creates a
-# socket that can publish to that topic. It exposes this functionality
-# using send_msg method
 import time
 import uuid
 from typing import Any, Dict

samples/apps/cap/py/autogencap/zmq_directory_svc.py

@@ -5,7 +5,6 @@
 import zmq
 
 from autogencap.actor import Actor
-from autogencap.zmq_actor_connector import ZMQActorConnector, ZMQActorSender
 from autogencap.broker import Broker
 from autogencap.constants import Directory_Svc_Topic
 from autogencap.debug_log import Debug, Error, Info
@@ -23,7 +22,7 @@
     Error as ErrorMsg,
 )
 from autogencap.utility import report_error_msg
-from autogencap.zmq_runtime import ZMQActorConnector, ZMQActorSender
+from autogencap.zmq_actor_connector import ZMQActorConnector, ZMQActorSender
 
 # TODO (Future DirectorySv PR) use actor description, network_id, other properties to make directory
 # service more generic and powerful

samples/apps/cap/py/autogencap/zmq_runtime.py

@@ -9,7 +9,6 @@
 from .broker import Broker
 from .constants import Termination_Topic
 from .debug_log import Debug, Warn
-from .zmq_directory_svc import ZMQDirectorySvc
 from .proto.CAP_pb2 import ActorInfo, ActorInfoCollection
 from .actor_connector import IActorConnector
 from .zmq_actor_connector import ZMQActorConnector
@@ -21,7 +20,7 @@ def __init__(self, start_broker: bool = True):
         self._context: zmq.Context = zmq.Context()
         self._start_broker: bool = start_broker
         self._broker: Broker = None
-        self._directory_svc: ZMQDirectorySvc = None
+        self._directory_svc = None
         self._log_name = self.__class__.__name__
 
     def __str__(self):
@@ -38,6 +37,7 @@ def _init_runtime(self):
                 self._start_broker = False  # Don't try to start the broker again
                 self._broker = None
         if self._directory_svc is None:
+            from .zmq_directory_svc import ZMQDirectorySvc
             self._directory_svc = ZMQDirectorySvc(self._context)
             self._directory_svc.start(self)
         time.sleep(0.25)  # Process queued thread events in Broker and Directory

samples/apps/cap/py/demo/complex_actor_demo.py

@@ -1,6 +1,6 @@
 import time
 
-from AppAgents import FidelityAgent, FinancialPlannerAgent, PersonalAssistant, QuantAgent, RiskManager
+from app_agents import FidelityAgent, FinancialPlannerAgent, PersonalAssistant, QuantAgent, RiskManager
 from autogencap.runtime_factory import RuntimeFactory
 from termcolor import colored
 

samples/apps/cap/py/demo/list_agents.py

@@ -1,7 +1,7 @@
 import time
 from typing import List
 
-from AppAgents import FidelityAgent, GreeterAgent
+from app_agents import FidelityAgent, GreeterAgent
 from autogencap.debug_log import Info
 from autogencap.proto.CAP_pb2 import ActorInfo
 from autogencap.runtime_factory import RuntimeFactory

samples/apps/cap/py/demo/simple_actor_demo.py

@@ -1,4 +1,4 @@
-from AppAgents import GreeterAgent
+from app_agents import GreeterAgent
 from autogencap.runtime_factory import RuntimeFactory
 
 

samples/apps/cap/py/demo/single_threaded.py

@@ -1,5 +1,5 @@
 import _paths
-from AppAgents import GreeterAgent
+from app_agents import GreeterAgent
 from autogencap.debug_log import Error
 from autogencap.proto.CAP_pb2 import Ping
 from autogencap.runtime_factory import RuntimeFactory